class RedisTagRepository implements TagRepository

Traits

Methods

array
pipeline(callable $callback)

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

__construct(Factory $redis)

Create a new repository instance.

array
monitoring()

Get the currently monitored tags.

array
monitored(array $tags)

Return the tags which are being monitored.

void
monitor(string $tag)

Start monitoring the given tag.

void
stopMonitoring(string $tag)

Stop monitoring the given tag.

void
add(string $id, array $tags)

Store the tags for the given job.

void
addTemporary(int $minutes, string $id, array $tags)

Store the tags for the given job temporarily.

int
count(string $tag)

Get the number of jobs matching a given tag.

array
jobs(string $tag)

Get all of the job IDs for a given tag.

array
paginate(string $tag, int $startingAt = 0, int $limit = 25)

Paginate the job IDs for a given tag.

void
forgetJobs(array|string $tags, array|string $ids)

Remove the given job IDs from the given tag.

void
forget(string $tag)

Delete the given tag from storage.

connection()

Get the Redis connection instance.

Details

protected array pipeline(callable $callback)

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

Parameters

callable $callback

Return Value

array

at line 20
__construct(Factory $redis)

Create a new repository instance.

Parameters

Factory $redis

the Redis connection instance

at line 28
array monitoring()

Get the currently monitored tags.

Return Value

array

at line 36
array monitored(array $tags)

Return the tags which are being monitored.

Parameters

array $tags

Return Value

array

at line 44
void monitor(string $tag)

Start monitoring the given tag.

Parameters

string $tag

Return Value

void

at line 52
void stopMonitoring(string $tag)

Stop monitoring the given tag.

Parameters

string $tag

Return Value

void

at line 60
void add(string $id, array $tags)

Store the tags for the given job.

Parameters

string $id
array $tags

Return Value

void

at line 72
void addTemporary(int $minutes, string $id, array $tags)

Store the tags for the given job temporarily.

Parameters

int $minutes
string $id
array $tags

Return Value

void

at line 86
int count(string $tag)

Get the number of jobs matching a given tag.

Parameters

string $tag

Return Value

int

at line 94
array jobs(string $tag)

Get all of the job IDs for a given tag.

Parameters

string $tag

Return Value

array

at line 102
array paginate(string $tag, int $startingAt = 0, int $limit = 25)

Paginate the job IDs for a given tag.

Parameters

string $tag
int $startingAt
int $limit

Return Value

array

at line 118
void forgetJobs(array|string $tags, array|string $ids)

Remove the given job IDs from the given tag.

Parameters

array|string $tags
array|string $ids

Return Value

void

at line 132
void forget(string $tag)

Delete the given tag from storage.

Parameters

string $tag

Return Value

void

at line 140
protected RedisProxy connection()

Get the Redis connection instance.

Return Value

RedisProxy