Versions in this module Expand all Collapse all v0 v0.5.0 Jul 28, 2016 Changes in this version + var ErrNotDeleted = fmt.Errorf("nothing deleted") + var ErrNotRetried = fmt.Errorf("nothing retried") + type Client struct + func NewClient(namespace string, pool *redis.Pool) *Client + func (c *Client) DeadJobs(page uint) ([]*DeadJob, int64, error) + func (c *Client) DeleteAllDeadJobs() error + func (c *Client) DeleteDeadJob(diedAt int64, jobID string) error + func (c *Client) DeleteRetryJob(retryAt int64, jobID string) error + func (c *Client) DeleteScheduledJob(scheduledFor int64, jobID string) error + func (c *Client) Queues() ([]*Queue, error) + func (c *Client) RetryAllDeadJobs() error + func (c *Client) RetryDeadJob(diedAt int64, jobID string) error + func (c *Client) RetryJobs(page uint) ([]*RetryJob, int64, error) + func (c *Client) ScheduledJobs(page uint) ([]*ScheduledJob, int64, error) + func (c *Client) WorkerObservations() ([]*WorkerObservation, error) + func (c *Client) WorkerPoolHeartbeats() ([]*WorkerPoolHeartbeat, error) + type DeadJob struct + DiedAt int64 + type Enqueuer struct + Namespace string + Pool *redis.Pool + func NewEnqueuer(namespace string, pool *redis.Pool) *Enqueuer + func (e *Enqueuer) Enqueue(jobName string, args map[string]interface{}) (*Job, error) + func (e *Enqueuer) EnqueueIn(jobName string, secondsFromNow int64, args map[string]interface{}) (*ScheduledJob, error) + func (e *Enqueuer) EnqueueUnique(jobName string, args map[string]interface{}) (*Job, error) + func (e *Enqueuer) EnqueueUniqueIn(jobName string, secondsFromNow int64, args map[string]interface{}) (*ScheduledJob, error) + type GenericHandler func(*Job) error + type GenericMiddlewareHandler func(*Job, NextMiddlewareFunc) error + type Job struct + Args map[string]interface{} + EnqueuedAt int64 + FailedAt int64 + Fails int64 + ID string + LastErr string + Name string + Unique bool + func (j *Job) ArgBool(key string) bool + func (j *Job) ArgError() error + func (j *Job) ArgFloat64(key string) float64 + func (j *Job) ArgInt64(key string) int64 + func (j *Job) ArgString(key string) string + func (j *Job) Checkin(msg string) + type JobOptions struct + MaxFails uint + Priority uint + SkipDead bool + type NextMiddlewareFunc func() error + type Q map[string]interface + type Queue struct + Count int64 + JobName string + Latency int64 + type RetryJob struct + RetryAt int64 + type ScheduledJob struct + RunAt int64 + type WorkerObservation struct + ArgsJSON string + Checkin string + CheckinAt int64 + IsBusy bool + JobID string + JobName string + StartedAt int64 + WorkerID string + type WorkerPool struct + func NewWorkerPool(ctx interface{}, concurrency uint, namespace string, pool *redis.Pool) *WorkerPool + func (wp *WorkerPool) Drain() + func (wp *WorkerPool) Job(name string, fn interface{}) *WorkerPool + func (wp *WorkerPool) JobWithOptions(name string, jobOpts JobOptions, fn interface{}) *WorkerPool + func (wp *WorkerPool) Middleware(fn interface{}) *WorkerPool + func (wp *WorkerPool) PeriodicallyEnqueue(spec string, jobName string) *WorkerPool + func (wp *WorkerPool) Start() + func (wp *WorkerPool) Stop() + type WorkerPoolHeartbeat struct + Concurrency uint + HeartbeatAt int64 + Host string + JobNames []string + Pid int + StartedAt int64 + WorkerIDs []string + WorkerPoolID string