JobRunnerPipeline Class Reference

Public Member Functions
	__construct (RedisJobService $service)
	initSlot ( $loop, $slot)
	refillSlots ( $loop, array $prioMap, array &$pending)
	terminateSlots ()

Protected Member Functions
	selectQueue ( $loop, array $prioMap, array $pending)
	spawnRunner ( $loop, $slot, $highPrio, array $queue, array &$procSlot)
	closeRunner ( $loop, $slot, array &$procSlot, $signal=null)

Protected Attributes
	$srvc
	$procMap = []

Constructor & Destructor Documentation

__construct()

JobRunnerPipeline::__construct

(

RedisJobService

$service

)

Parameters

RedisJobService

$service

Member Function Documentation

closeRunner()

JobRunnerPipeline::closeRunner ( $loop, $slot, array & $procSlot, $signal = null )

protected

Parameters

int	$loop
int	$slot
array	&$procSlot
int | null	$signal

initSlot()

JobRunnerPipeline::initSlot	(		$loop,
			$slot )

Parameters

string	$loop
int	$slot

refillSlots()

JobRunnerPipeline::refillSlots	(		$loop,
		array	$prioMap,
		array &	$pending )

Parameters

int	$loop
array	$prioMap
array	&$pending

Returns

array

selectQueue()

JobRunnerPipeline::selectQueue ( $loop, array $prioMap, array $pending )

protected

Parameters

int	$loop
array	$prioMap
array	$pending

Returns

array|bool

spawnRunner()

JobRunnerPipeline::spawnRunner ( $loop, $slot, $highPrio, array $queue, array & $procSlot )

protected

Parameters

int	$loop
int	$slot
bool	$highPrio
array	$queue
array	&$procSlot

Returns

bool

---

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

• src/JobRunnerPipeline.php