Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Queue ¶
type Queue struct {
Name string
// contains filtered or unexported fields
}
Queue holds a reference to a redis connection and a queue name.
func (*Queue) FlushQueue ¶
FlushQueue removes everything from the queue. Useful for testing.
func (*Queue) Pending ¶
Pending returns the count of jobs pending, including scheduled jobs that are not due yet.
func (*Queue) 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 connections)
func (*Queue) PopJobs ¶
PopJobs returns multiple jobs from the queue. Safe for concurrent use (multiple goroutines must use their own Queue objects and redis connections)
Source Files
Click to show internal directories.
Click to hide internal directories.