manager

May 9, 2023

Changes in this version

+ const MiddlewareHelperKey

Jun 7, 2022

Changes in this version

type Manager

+ PauseQueue func(qName string) error

+ RemoveQueue func(qName string) error

+ ResumeQueue func(qName string) error

Mar 1, 2021

Changes in this version

+ const DeadTTL

+ const DefaultTimeout

+ var JobReservationExpired = &FailPayload

+ func Discard(msg string) error

+ func ExpectedError(code string, msg string) error

+ func Halt(code string, msg string) error

+ type BasicFetch struct

+ func (f *BasicFetch) Fetch(ctx context.Context, wid string, queues ...string) (Lease, error)

+ type Context interface

+ Job func() *client.Job

+ Manager func() Manager

+ Reservation func() *Reservation

+ type Ctx struct

+ func (c Ctx) Job() *client.Job

+ func (c Ctx) Manager() Manager

+ func (c Ctx) Reservation() *Reservation

+ type FailPayload struct

+ Backtrace []string

+ ErrorMessage string

+ ErrorType string

+ Jid string

+ type Fetcher interface

+ Fetch func(ctx context.Context, wid string, queues ...string) (Lease, error)

+ func BasicFetcher(r *redis.Client) Fetcher

+ type KnownError interface

+ Code func() string

+ type Lease interface

+ Job func() (*client.Job, error)

+ Payload func() []byte

+ Release func() error

+ var Nothing Lease = &simpleLease{}

+ type Manager interface

+ Acknowledge func(jid string) (*client.Job, error)

+ AddMiddleware func(fntype string, fn MiddlewareFunc)

+ BusyCount func(wid string) int

+ EnqueueScheduledJobs func(when time.Time) (int64, error)

+ ExtendReservation func(jid string, until time.Time) error

+ Fail func(fail *FailPayload) error

+ Fetch func(ctx context.Context, wid string, queues ...string) (*client.Job, error)

+ KV func() storage.KV

+ Pause func(qName string) error

+ Purge func(when time.Time) (int64, error)

+ Push func(job *client.Job) error

+ ReapExpiredJobs func(when time.Time) (int64, error)

+ Redis func() *redis.Client

+ Resume func(qName string) error

+ RetryJobs func(when time.Time) (int64, error)

+ SetFetcher func(f Fetcher)

+ WorkingCount func() int

+ func NewManager(s storage.Store) Manager

+ type MiddlewareChain []MiddlewareFunc

+ type MiddlewareFunc func(next func() error, ctx Context) error

+ type Reservation struct

+ Expiry string

+ Job *client.Job

+ Since string

+ Wid string

+ func (res *Reservation) ExpiresAt() time.Time

+ func (res *Reservation) ReservedAt() time.Time