1. class
  2. Hypervel
  3. \
  4. Horizon
  5. \
  6. Repositories
  7. \
  8. RedisProcessRepository

RedisProcessRepository

class RedisProcessRepository implements ProcessRepository

Traits

UsesClusterAwarePipeline

Methods

array
pipeline(callable $callback)

Execute commands in a pipeline, falling back to a transaction.

from  UsesClusterAwarePipeline
__construct(Factory $redis)

Create a new repository instance.

array
allOrphans(string $master)

Get all of the orphan process IDs and the times they were observed.

void
orphaned(string $master, array $processIds)

Record the given process IDs as orphaned.

array
orphanedFor(string $master, int $seconds)

Get the process IDs orphaned for at least the given number of seconds.

void
forgetOrphans(string $master, array $processIds)

Remove the given process IDs from the orphan list.

RedisProxy
connection()

Get the Redis connection instance.

Details

in UsesClusterAwarePipeline at line 12
protected array pipeline(callable $callback)

Execute commands in a pipeline, falling back to a transaction.

Parameters

callable $callback

Return Value

array

at line 21
__construct(Factory $redis)

Create a new repository instance.

Parameters

Factory $redis

the Redis connection instance

at line 29
array allOrphans(string $master)

Get all of the orphan process IDs and the times they were observed.

Parameters

string $master

Return Value

array

at line 39
void orphaned(string $master, array $processIds)

Record the given process IDs as orphaned.

Parameters

string $master
array $processIds

Return Value

void

at line 61
array orphanedFor(string $master, int $seconds)

Get the process IDs orphaned for at least the given number of seconds.

Parameters

string $master
int $seconds

Return Value

array

at line 73
void forgetOrphans(string $master, array $processIds)

Remove the given process IDs from the orphan list.

Parameters

string $master
array $processIds

Return Value

void

at line 84
protected RedisProxy connection()

Get the Redis connection instance.

Return Value

RedisProxy