1. class
  2. Hypervel
  3. \
  4. Horizon
  5. \
  6. WaitTimeCalculator

WaitTimeCalculator

class WaitTimeCalculator

Methods

__construct(Factory $queue, SupervisorRepository $supervisors, MetricsRepository $metrics)

Create a new calculator instance.

float
calculateFor(string $queue)

Calculate the time to clear a given queue in seconds.

array
calculate(string|null $queue = null)

Calculate the time to clear per queue in seconds.

Collection
queueNames(Collection $supervisors, string|null $queue = null)

Get all of the queue names.

int
totalProcessesFor(Collection $allSupervisors, string $queue)

Get the total process count for a given queue.

float
calculateTimeToClear(string $connection, string $queue, int $totalProcesses)

Calculate the time to clear for the given queue in seconds distributed over the given amount of processes.

float
timeToClearFor(string $connection, string $queue)

Get the total time to clear (in milliseconds) for a given queue.

Details

at line 18
__construct(Factory $queue, SupervisorRepository $supervisors, MetricsRepository $metrics)

Create a new calculator instance.

Parameters

Factory $queue
SupervisorRepository $supervisors
MetricsRepository $metrics

at line 28
float calculateFor(string $queue)

Calculate the time to clear a given queue in seconds.

Parameters

string $queue

Return Value

float

at line 38
array calculate(string|null $queue = null)

Calculate the time to clear per queue in seconds.

Parameters

string|null $queue

Return Value

array

at line 57
protected Collection queueNames(Collection $supervisors, string|null $queue = null)

Get all of the queue names.

Parameters

Collection $supervisors
string|null $queue

Return Value

Collection

at line 71
protected int totalProcessesFor(Collection $allSupervisors, string $queue)

Get the total process count for a given queue.

Parameters

Collection $allSupervisors
string $queue

Return Value

int

at line 81
float calculateTimeToClear(string $connection, string $queue, int $totalProcesses)

Calculate the time to clear for the given queue in seconds distributed over the given amount of processes.

Parameters

string $connection
string $queue
int $totalProcesses

Return Value

float

at line 97
protected float timeToClearFor(string $connection, string $queue)

Get the total time to clear (in milliseconds) for a given queue.

Parameters

string $connection
string $queue

Return Value

float