Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/agilebits/go-redis-queue
/ functions
Functions
13 in github.com/agilebits/go-redis-queue
⨍
Functions
13
◇
Types & classes
1
↓ 8 callers
Method
Schedule
Schedule schedule a job at some point in the future, or some point in the past. Scheduling a job far in the past is the same as giving it a high prior
redisqueue/queue.go:31
↓ 7 callers
Method
Pop
Pop removes and returns a single job from the queue. Safe for concurrent use (multiple goroutines must use their own Queue objects and redis connectio
redisqueue/queue.go:51
↓ 4 callers
Method
FlushQueue
FlushQueue removes everything from the queue. Useful for testing.
redisqueue/queue.go:45
↓ 2 callers
Method
Pending
Pending returns the count of jobs pending, including scheduled jobs that are not due yet.
redisqueue/queue.go:40
↓ 2 callers
Method
PopJobs
PopJobs returns multiple jobs from the queue. Safe for concurrent use (multiple goroutines must use their own Queue objects and redis connections)
redisqueue/queue.go:63
↓ 2 callers
Method
Push
Push pushes a single job on to the queue. The job string can be any format, as the queue doesn't really care.
redisqueue/queue.go:26
Function
New
New defines a new Queue
redisqueue/queue.go:18
Function
TestPopMultiOrder
(t *testing.T)
redisqueue/queue_test.go:190
Function
TestPopOrder
(t *testing.T)
redisqueue/queue_test.go:116
Function
TestQueueTaskScheduling
(t *testing.T)
redisqueue/queue_test.go:57
Function
TestQueueTasks
(t *testing.T)
redisqueue/queue_test.go:11
Function
init
()
redisqueue/scripts.go:7
Function
quoteArgs
(args []string)
redisqueue/queue.go:67