Handle enqueueing of background jobs. More...

Collaboration diagram for MediaWiki\JobQueue\JobQueueGroup:

[legend]

Public Member Functions
	__construct ( $domain, ReadOnlyMode $readOnlyMode, ?array $localJobClasses, array $jobTypeConfiguration, array $jobTypesExcludedFromDefaultQueue, StatsFactory $statsFactory, WANObjectCache $wanCache, GlobalIdGenerator $globalIdGenerator)

	ack (RunnableJob $job)
	Acknowledge that a job was completed.

	deduplicateRootJob (RunnableJob $job)
	Register the "root job" of a given job into the queue for de-duplication.

	get ( $type)
	Get the job queue object for a given queue type.

	getDefaultQueueTypes ()
	Get the list of default queue types.

	getQueueSizes ()
	Get the size of the queues for a list of job types.

	getQueuesWithJobs ()
	Get the list of job types that have non-empty queues.

	getQueueTypes ()
	Get the list of queue types.

	lazyPush ( $jobs)
	Buffer jobs for insertion via push() or call it now if in CLI mode.

	pop ( $qtype=self::TYPE_DEFAULT, $flags=0, array $ignored=[])
	Pop one job off a job queue.

	push ( $jobs)
	Insert jobs into the respective queues of which they belong.

	queuesHaveJobs ( $type=self::TYPE_ANY)
	Check if there are any queues with jobs (this is cached)

	waitForBackups ()
	Wait for any replica DBs or backup queue servers to catch up.

Public Attributes
const	TYPE_DEFAULT = 1

const	USE_CACHE = 1

Protected Member Functions
	getCoalescedQueues ()

Protected Attributes
MapCacheLRU	$cache

array	$coalescedQueues
	Map of (bucket => (queue => JobQueue, types => list of types)

string	$domain
	Wiki domain ID.

ReadOnlyMode	$readOnlyMode
	Read only mode.

Detailed Description

Handle enqueueing of background jobs.

Warning: This service class supports queuing jobs to foreign wikis via JobQueueGroupFactory, but other operations may be called for the local wiki only. Exceptions may be thrown if you attempt to inspect, pop, or execute a foreign wiki's job queue.

Since: 1.21

Definition at line 44 of file JobQueueGroup.php.

Constructor & Destructor Documentation

◆ __construct()

MediaWiki\JobQueue\JobQueueGroup::__construct	(		$domain,
		ReadOnlyMode	$readOnlyMode,
		?array	$localJobClasses,
		array	$jobTypeConfiguration,
		array	$jobTypesExcludedFromDefaultQueue,
		StatsFactory	$statsFactory,
		WANObjectCache	$wanCache,
		GlobalIdGenerator	$globalIdGenerator )

Access: internal: Use MediaWikiServices::getJobQueueGroupFactory

Parameters

string	$domain	Wiki domain ID
ReadOnlyMode	$readOnlyMode	Read-only mode
array \| null	$localJobClasses
array	$jobTypeConfiguration
array	$jobTypesExcludedFromDefaultQueue
StatsFactory	$statsFactory
WANObjectCache	$wanCache
GlobalIdGenerator	$globalIdGenerator

Definition at line 88 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\$domain, and MediaWiki\JobQueue\JobQueueGroup\$readOnlyMode.

Member Function Documentation

◆ ack()

MediaWiki\JobQueue\JobQueueGroup::ack ( RunnableJob $job )

Acknowledge that a job was completed.

Parameters

RunnableJob $job

Returns: void

Definition at line 276 of file JobQueueGroup.php.

References $job, MediaWiki\JobQueue\JobQueueGroup\ack(), and MediaWiki\JobQueue\IJobSpecification\getType().

Referenced by MediaWiki\JobQueue\JobQueueGroup\ack().

◆ deduplicateRootJob()

MediaWiki\JobQueue\JobQueueGroup::deduplicateRootJob ( RunnableJob $job )

Register the "root job" of a given job into the queue for de-duplication.

This should only be called right after all the new jobs have been inserted.

Deprecated: since 1.40

Parameters

RunnableJob $job

Returns: bool

Definition at line 288 of file JobQueueGroup.php.

References wfDeprecated().

◆ get()

MediaWiki\JobQueue\JobQueueGroup::get ( $type )

Get the job queue object for a given queue type.

Parameters

string $type

Returns: JobQueue

Definition at line 115 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\$domain, and MediaWiki\JobQueue\JobQueue\factory().

Referenced by MediaWiki\Api\ApiUpload\__construct().

◆ getCoalescedQueues()

MediaWiki\JobQueue\JobQueueGroup::getCoalescedQueues ( )

protected

Returns: array[]

Definition at line 417 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\$coalescedQueues, MediaWiki\JobQueue\JobQueueGroup\$domain, MediaWiki\JobQueue\JobQueue\factory(), and MediaWiki\JobQueue\JobQueueGroup\getQueueTypes().

Referenced by MediaWiki\JobQueue\JobQueueGroup\getQueueSizes(), and MediaWiki\JobQueue\JobQueueGroup\getQueuesWithJobs().

◆ getDefaultQueueTypes()

MediaWiki\JobQueue\JobQueueGroup::getDefaultQueueTypes ( )

Get the list of default queue types.

Warning: May not be called on foreign wikis!

Returns: string[]

Definition at line 331 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\getQueueTypes().

Referenced by MediaWiki\JobQueue\JobQueueGroup\pop(), and MediaWiki\JobQueue\JobQueueGroup\queuesHaveJobs().

◆ getQueueSizes()

MediaWiki\JobQueue\JobQueueGroup::getQueueSizes ( )

Get the size of the queues for a list of job types.

Warning: May not be called on foreign wikis!

Returns: int[] Map of (job type => size)

Definition at line 395 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\getCoalescedQueues(), and MediaWiki\JobQueue\JobQueueGroup\getQueueTypes().

◆ getQueuesWithJobs()

MediaWiki\JobQueue\JobQueueGroup::getQueuesWithJobs ( )

Get the list of job types that have non-empty queues.

Warning: May not be called on foreign wikis!

Returns: string[] List of job types that have non-empty queues

Definition at line 368 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\getCoalescedQueues(), and MediaWiki\JobQueue\JobQueueGroup\getQueueTypes().

Referenced by MediaWiki\JobQueue\JobQueueGroup\pop(), and MediaWiki\JobQueue\JobQueueGroup\queuesHaveJobs().

◆ getQueueTypes()

MediaWiki\JobQueue\JobQueueGroup::getQueueTypes ( )

Get the list of queue types.

Warning: May not be called on foreign wikis!

Returns: string[]

Definition at line 317 of file JobQueueGroup.php.

Referenced by MediaWiki\JobQueue\JobQueueGroup\getCoalescedQueues(), MediaWiki\JobQueue\JobQueueGroup\getDefaultQueueTypes(), MediaWiki\JobQueue\JobQueueGroup\getQueueSizes(), and MediaWiki\JobQueue\JobQueueGroup\getQueuesWithJobs().

◆ lazyPush()

MediaWiki\JobQueue\JobQueueGroup::lazyPush ( $jobs )

Buffer jobs for insertion via push() or call it now if in CLI mode.

Parameters

IJobSpecification | IJobSpecification[] $jobs A single Job or a list of Jobs

Returns: void

Since: 1.26

Definition at line 196 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\push().

◆ pop()

MediaWiki\JobQueue\JobQueueGroup::pop	(		$qtype = self::TYPE_DEFAULT,
			$flags = 0,
		array	$ignored = [] )

Pop one job off a job queue.

Warning: May not be called on foreign wikis!

This pops a job off a queue as specified by $wgJobTypeConf and updates the aggregate job queue information cache as needed.

Parameters

int \| string	$qtype	JobQueueGroup::TYPE_* constant or job type string
int	$flags	Bitfield of JobQueueGroup::USE_* constants
array	$ignored	List of job types to ignore

Returns: RunnableJob|false Returns false on failure

Exceptions

JobQueueError

Definition at line 224 of file JobQueueGroup.php.

References $job, MediaWiki\JobQueue\JobQueueGroup\getDefaultQueueTypes(), MediaWiki\JobQueue\JobQueueGroup\getQueuesWithJobs(), and MediaWiki\JobQueue\JobQueueGroup\pop().

Referenced by MediaWiki\JobQueue\JobQueueGroup\pop().

◆ push()

MediaWiki\JobQueue\JobQueueGroup::push ( $jobs )

Insert jobs into the respective queues of which they belong.

This inserts the jobs into the queue specified by $wgJobTypeConf and updates the aggregate job queue information cache as needed.

Parameters

IJobSpecification | IJobSpecification[] $jobs A single Job or a list of Jobs

Returns: void

Definition at line 138 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\$cache, $job, MediaWiki\MediaWikiServices\getInstance(), MediaWiki\JobQueue\JobQueueGroup\push(), and Wikimedia\MapCacheLRU\MapCacheLRU\set().

Referenced by MediaWiki\JobQueue\JobQueueGroup\lazyPush(), and MediaWiki\JobQueue\JobQueueGroup\push().

◆ queuesHaveJobs()

MediaWiki\JobQueue\JobQueueGroup::queuesHaveJobs ( $type = self::TYPE_ANY )

Check if there are any queues with jobs (this is cached)

Warning: May not be called on foreign wikis!

Since: 1.23

Parameters

int $type JobQueueGroup::TYPE_* constant

Returns: bool

Definition at line 344 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\$cache, Wikimedia\MapCacheLRU\MapCacheLRU\get(), MediaWiki\JobQueue\JobQueueGroup\getDefaultQueueTypes(), MediaWiki\MediaWikiServices\getInstance(), and MediaWiki\JobQueue\JobQueueGroup\getQueuesWithJobs().

◆ waitForBackups()

MediaWiki\JobQueue\JobQueueGroup::waitForBackups ( )

Wait for any replica DBs or backup queue servers to catch up.

This does nothing for certain queue classes.

Deprecated: since 1.41, use JobQueue::waitForBackups() instead.

Returns: void

Definition at line 302 of file JobQueueGroup.php.

References MediaWiki\JobQueue\JobQueueGroup\waitForBackups(), and wfDeprecated().

Referenced by MediaWiki\JobQueue\JobQueueGroup\waitForBackups().

Member Data Documentation

◆ $cache

MapCacheLRU MediaWiki\JobQueue\JobQueueGroup::$cache

protected

Definition at line 46 of file JobQueueGroup.php.

Referenced by MediaWiki\JobQueue\JobQueueGroup\push(), and MediaWiki\JobQueue\JobQueueGroup\queuesHaveJobs().

◆ $coalescedQueues

array MediaWiki\JobQueue\JobQueueGroup::$coalescedQueues

protected

Map of (bucket => (queue => JobQueue, types => list of types)

Definition at line 66 of file JobQueueGroup.php.

Referenced by MediaWiki\JobQueue\JobQueueGroup\getCoalescedQueues().

◆ $domain

string MediaWiki\JobQueue\JobQueueGroup::$domain

protected

Wiki domain ID.

Definition at line 49 of file JobQueueGroup.php.

Referenced by MediaWiki\JobQueue\JobQueueGroup\__construct(), MediaWiki\JobQueue\JobQueueGroup\get(), and MediaWiki\JobQueue\JobQueueGroup\getCoalescedQueues().

◆ $readOnlyMode

ReadOnlyMode MediaWiki\JobQueue\JobQueueGroup::$readOnlyMode

protected

Read only mode.

Definition at line 51 of file JobQueueGroup.php.

Referenced by MediaWiki\JobQueue\JobQueueGroup\__construct().

◆ TYPE_DEFAULT

const MediaWiki\JobQueue\JobQueueGroup::TYPE_DEFAULT = 1

Definition at line 68 of file JobQueueGroup.php.

Referenced by MediaWiki\JobQueue\JobRunner\run().

◆ USE_CACHE

const MediaWiki\JobQueue\JobQueueGroup::USE_CACHE = 1

Definition at line 71 of file JobQueueGroup.php.

Referenced by MediaWiki\JobQueue\JobRunner\run().

The documentation for this class was generated from the following file:

includes/jobqueue/JobQueueGroup.php

Public Member Functions

Public Attributes

Protected Member Functions

Protected Attributes

Detailed Description

Constructor & Destructor Documentation

◆ __construct()

Member Function Documentation

◆ ack()

◆ deduplicateRootJob()

◆ get()

◆ getCoalescedQueues()

◆ getDefaultQueueTypes()

◆ getQueueSizes()

◆ getQueuesWithJobs()

◆ getQueueTypes()

◆ lazyPush()

◆ pop()

◆ push()

◆ queuesHaveJobs()

◆ waitForBackups()

Member Data Documentation

◆ $cache

◆ $coalescedQueues

◆ $domain

◆ $readOnlyMode

◆ TYPE_DEFAULT

◆ USE_CACHE