work

Mar 26, 2024

Changes in this version

+ const WatchdogFailCheckingTimeout

+ type WatchdogStat struct

+ Name string

+ Processed int64

+ Skipped int64

type WorkerPool

+ func (wp *WorkerPool) WatchdogStats() []WatchdogStat

type WorkerPoolOption

+ func WithWatchdogFailCheckingTimeout(p time.Duration) WorkerPoolOption

Jan 31, 2024

Changes in this version

+ type ClientOption func(*Client)

+ func WithClientLogger(l StructuredLogger) ClientOption

+ type ReapResult struct

+ DanglingLockJobs []string

+ Err error

+ NoPoolHeartBeatJobs []string

+ UnknownPoolJobs []string

+ type ReaperHook func() (afterHook func(ReapResult))

+ type StructuredLogger interface

+ Debug func(msg string, args ...any)

+ DebugContext func(ctx context.Context, msg string, args ...any)

+ Error func(msg string, args ...any)

+ ErrorContext func(ctx context.Context, msg string, args ...any)

+ Info func(msg string, args ...any)

+ InfoContext func(ctx context.Context, msg string, args ...any)

+ Warn func(msg string, args ...any)

+ WarnContext func(ctx context.Context, msg string, args ...any)

type WorkerPoolOption

+ func WithLogger(l StructuredLogger) WorkerPoolOption

+ func WithReaperHook(h ReaperHook) WorkerPoolOption

Mar 27, 2023

Changes in this version

+ type WorkerPoolOption func(wp *WorkerPool)

+ func WithReapPeriod(p time.Duration) WorkerPoolOption

Feb 15, 2023

Changes in this version

type Enqueuer

+ func (e *Enqueuer) EnqueueContext(ctx context.Context, jobName string, args Q) (*Job, error)

+ func (e *Enqueuer) EnqueueContextIn(ctx context.Context, jobName string, secondsFromNow int64, args Q) (*ScheduledJob, error)

+ func (e *Enqueuer) EnqueueContextUnique(ctx context.Context, jobName string, args Q) (*Job, error)

+ func (e *Enqueuer) EnqueueContextUniqueIn(ctx context.Context, jobName string, secondsFromNow int64, args Q) (*ScheduledJob, error)

type Job

+ TraceContext map[string]string

+ type JobContextHandler = func(context.Context, *Job) error

+ type JobContextMiddleware = func(context.Context, *Job, JobContextHandler) error

+ type JobHandler = func(*Job) error

+ type JobMiddleware = func(*Job, NextMiddlewareFunc) error

Nov 2, 2022

Changes in this version

type Job

+ StartingDeadline int64

Aug 5, 2022

Changes in this version

+ type Pool interface

+ Get func() redis.Conn

Jul 7, 2022

Changes in this version

+ type StdLogger interface

+ Print func(v ...interface{})

+ Printf func(format string, v ...interface{})

+ Println func(v ...interface{})

+ var Logger StdLogger = log.New(io.Discard, "[Work] ", log.LstdFlags)

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