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

RedisHorizonCommandQueue

class RedisHorizonCommandQueue implements HorizonCommandQueue

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 command queue instance.

void
push(string $name, string $command, array $options = [])

Push a command onto a given queue.

array
pending(string $name)

Get the pending commands for a given queue name.

void
flush(string $name)

Flush the command queue for a given queue name.

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 19
__construct(Factory $redis)

Create a new command queue instance.

Parameters

Factory $redis

at line 27
void push(string $name, string $command, array $options = [])

Push a command onto a given queue.

Parameters

string $name
string $command
array $options

Return Value

void

at line 38
array pending(string $name)

Get the pending commands for a given queue name.

Parameters

string $name

Return Value

array

at line 61
void flush(string $name)

Flush the command queue for a given queue name.

Parameters

string $name

Return Value

void

at line 69
protected RedisProxy connection()

Get the Redis connection instance.

Return Value

RedisProxy