Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNoConnection = errors.New("Disque Error: no client nor connection is provided!")
ErrNoConnection is the error thrown when no connection options are provided
View Source
var FetchTimeout = "10s"
FetchTimeout is the default fetch timeout
View Source
var JobTimeout = "5s"
JobTimeout is the default job timeout
Functions ¶
func AckJob ¶
func AckJob(client *disque.DisquePool, id string) (err error)
AckJob sends an ACK about a job to the queue
Types ¶
type Job ¶
type Job struct { ID string QueueName string Body string ETA time.Time CreatedAt time.Time UpdatedAt time.Time Raw *disque.JobDetails }
Job is the job struct
func AddJob ¶
func AddJob(client *disque.DisquePool, queueName string, body string, ETA time.Time, options *map[string]string) (job *Job, err error)
AddJob adds a job to the queue
Click to show internal directories.
Click to hide internal directories.