work

May 22, 2018

Changes in this version

+ type BackoffCalculator func(job *Job) int64

type JobOptions

+ Backoff BackoffCalculator

+ MaxConcurrency uint

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