PHP memory-backed job queue storage, for testing. More...

Collaboration diagram for JobQueueMemory:

[legend]

Public Member Functions
	__construct (array $params)

	getAllAcquiredJobs ()

	getAllQueuedJobs ()

	jobFromSpecInternal (IJobSpecification $spec)

Public Member Functions inherited from JobQueue
	ack (RunnableJob $job)
	Acknowledge that a job was completed.

	batchPush (array $jobs, $flags=0)
	Push a batch of jobs into the queue.

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

	delayedJobsEnabled ()

	delete ()
	Delete all unclaimed and delayed jobs from the queue.

	flushCaches ()
	Clear any process and persistent caches.

	getAbandonedCount ()
	Get the number of acquired jobs that can no longer be attempted.

	getAcquiredCount ()
	Get the number of acquired jobs (these are temporarily out of the queue).

	getAllAbandonedJobs ()
	Get an iterator to traverse over all abandoned jobs in this queue.

	getAllDelayedJobs ()
	Get an iterator to traverse over all delayed jobs in this queue.

	getCoalesceLocationInternal ()
	Do not use this function outside of JobQueue/JobQueueGroup.

	getDelayedCount ()
	Get the number of delayed jobs (these are temporarily out of the queue).

	getDomain ()

	getOrder ()

	getReadOnlyReason ()

	getSiblingQueueSizes (array $types)
	Check the size of each of the given queues.

	getSiblingQueuesWithJobs (array $types)
	Check whether each of the given queues are empty.

	getSize ()
	Get the number of available (unacquired, non-delayed) jobs in the queue.

	getType ()

	isEmpty ()
	Quickly check if the queue has no available (unacquired, non-delayed) jobs.

	pop ()
	Pop a job off of the queue.

	push ( $jobs, $flags=0)
	Push one or more jobs into the queue.

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

Protected Member Functions

doAck (RunnableJob $job)

doBatchPush (array $jobs, $flags)

doDelete ()

Stability: stable: to override

See also: JobQueue::delete()

Exceptions

JobQueueError

doGetAcquiredCount ()

doGetSize ()

doIsEmpty ()

doPop ()

optimalOrder ()

supportedOrders ()

Protected Member Functions inherited from JobQueue

assertNotReadOnly ()

doDeduplicateRootJob (IJobSpecification $job)

doFlushCaches ()

doGetAbandonedCount ()

doGetDelayedCount ()

doGetSiblingQueueSizes (array $types)

doGetSiblingQueuesWithJobs (array $types)

doIsRootJobOldDuplicate (IJobSpecification $job)

doWaitForBackups ()

factoryJob ( $command, $params)

getRootJobCacheKey ( $signature, $type)

incrStats ( $key, $type, $delta=1)

Call StatsdDataFactoryInterface::updateCount() for the queue overall and for the queue type.

isRootJobOldDuplicate (IJobSpecification $job)

Check if the "root" job of a given job has been superseded by a newer one.

supportsDelayedJobs ()

Find out if delayed jobs are supported for configuration validation.

supportsTypeAgnostic ()

Subclasses should set this to true if they support type agnostic queues.

Static Protected Attributes
static array[]	$data = []

Additional Inherited Members
Static Public Member Functions inherited from JobQueue
static	factory (array $params)
	Get a job queue object of the specified type.

Protected Attributes inherited from JobQueue
int	$claimTTL
	Time to live in seconds.

string	$domain
	DB domain ID.

GlobalIdGenerator	$idGenerator

int	$maxTries
	Maximum number of times to try a job.

string	$order
	Job priority for pop()

string false	$readOnlyReason
	Read only rationale (or false if r/w)

StatsdDataFactoryInterface	$stats

string	$type
	Job type.

bool	$typeAgnostic

WANObjectCache	$wanCache

const	QOS_ATOMIC = 1

const	ROOTJOB_TTL = 28 * 24 * 3600

Detailed Description

PHP memory-backed job queue storage, for testing.

JobQueueGroup does not remember every queue instance, so statically track it here.

Since: 1.27

Definition at line 32 of file JobQueueMemory.php.

Constructor & Destructor Documentation

◆ __construct()

JobQueueMemory::__construct ( array $params )

Stability: stable: to call

Parameters

array

$params

type : A job type, 'default' if typeAgnostic is set

domain : A DB domain ID
idGenerator : A GlobalIdGenerator instance.
wanCache : An instance of WANObjectCache to use for caching [default: none]
stats : An instance of StatsdDataFactoryInterface [default: none]
claimTTL : Seconds a job can be claimed for exclusive execution [default: forever]
maxTries : Total times a job can be tried, assuming claims expire [default: 3]
order : Queue order, one of ("fifo", "timestamp", "random") [default: variable]
readOnlyReason : Mark the queue as read-only with this reason [default: false]
typeAgnostic : If the jobqueue should operate agnostic to the job types
Exceptions

JobQueueError