Class to handle tracking information about all queues using PhpRedis. More...

Inheritance diagram for JobQueueAggregatorRedis:

Collaboration diagram for JobQueueAggregatorRedis:

Public Member Functions
	__construct (array $params)

Public Member Functions inherited from JobQueueAggregator
	__construct (array $params)

	getAllReadyWikiQueues ()
	Get the list of all of the queues with jobs. More...

	notifyQueueEmpty ($wiki, $type)
	Mark a queue as being empty. More...

	notifyQueueNonEmpty ($wiki, $type)
	Mark a queue as being non-empty. More...

	purge ()
	Purge all of the aggregator information. More...

Protected Member Functions
	doGetAllReadyWikiQueues ()

	doNotifyQueueEmpty ($wiki, $type)

	doNotifyQueueNonEmpty ($wiki, $type)

	doPurge ()

	getConnection ()
	Get a connection to the server that handles all sub-queues for this queue. More...

Protected Member Functions inherited from JobQueueAggregator
	doGetAllReadyWikiQueues ()

	doNotifyQueueEmpty ($wiki, $type)

	doNotifyQueueNonEmpty ($wiki, $type)

	doPurge ()

	findPendingWikiQueues ()
	Get all databases that have a pending job. More...

Protected Attributes
RedisConnectionPool	$redisPool

array	$servers
	List of Redis server addresses. More...

Additional Inherited Members
Static Public Member Functions inherited from JobQueueAggregator
static	destroySingleton ()
	Destroy the singleton instance. More...

static	singleton ()

Static Protected Attributes inherited from JobQueueAggregator
static JobQueueAggregator	$instance = null

Detailed Description

Class to handle tracking information about all queues using PhpRedis.

The mediawiki/services/jobrunner background service must be set up and running.

Constructor & Destructor Documentation

JobQueueAggregatorRedis::__construct ( array $params )

Parameters

array

$params

Possible keys:

redisConfig : An array of parameters to RedisConnectionPool::__construct().
redisServers : Array of server entries, the first being the primary and the others being fallback servers. Each entry is either a hostname/port combination or the absolute path of a UNIX socket. If a hostname is specified but no port, the standard port number 6379 will be used. Required.