work

package module

Go to main page

Versions in this module

v0

v0.5.6

Jul 20, 2026

v0.5.5

Jul 6, 2026

v0.5.4

May 29, 2025

v0.5.3

Feb 14, 2024

v0.5.2

Feb 14, 2023

Changes in this version

type Enqueuer

+ func (e *Enqueuer) EnqueueUniqueByKey(jobName string, args map[string]interface{}, keyMap map[string]interface{}) (*Job, error)

+ func (e *Enqueuer) EnqueueUniqueInByKey(jobName string, secondsFromNow int64, args map[string]interface{}, ...) (*ScheduledJob, error)

type Job

+ Context context.Context

+ UniqueKey string

+ func (j *Job) ArgInt64Slice(key string) []int64

+ type Worker interface

+ Drain func()

+ Job func(name string, fn interface{}) Worker

+ JobWithOptions func(name string, jobOpts JobOptions, fn interface{}) Worker

+ Middleware func(fn interface{}) Worker

+ PeriodicallyEnqueue func(spec string, jobName string) Worker

+ Start func()

+ Stop func()

+ func NewWorkerPoolWithOptions(ctx interface{}, concurrency uint, namespace string, pool *redis.Pool, ...) Worker

+ type WorkerPoolOptions struct

+ SleepBackoffs []int64

v0.5.1

May 22, 2018

Changes in this version

+ type BackoffCalculator func(job *Job) int64

type JobOptions

+ Backoff BackoffCalculator

+ MaxConcurrency uint

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL