handler

Apr 16, 2024

Changes in this version

+ func DefaultRecoveryCallback(_ context.Context, _ error) (err error)

type Handler

+ RecoverCallback RecoveryCallback

type Option

+ func RecoverCallback(f RecoveryCallback) Option

+ type RecoveryCallback func(ctx context.Context, err error) (erro error)

Sep 16, 2023

Changes in this version

type Handler

+ Queue string

+ func NewPeriodic(f Func, opts ...Option) (h Handler)

type Option

+ func Queue(queue string) Option

Apr 15, 2023

Changes in this version

+ const DefaultHandlerTimeout

type Handler

+ JobTimeout time.Duration

type Option

+ func JobTimeout(d time.Duration) Option

Mar 21, 2023

Changes in this version

type Handler

+ JobsChannel chan *jobs.Job

Mar 17, 2023

Changes in this version

+ var JobCtxVarKey contextKey

+ func WithJobContext(ctx context.Context, j *jobs.Job) context.Context

Mar 7, 2023

Changes in this version

+ const DefaultHandlerDeadline

+ var CtxVarsKey contextKey

+ var ErrContextHasNoJob = errors.New("context has no Job")

+ var ErrNoHandlerForQueue = errors.New("no handler for queue")

+ var ErrNoProcessorForQueue = errors.New("no processor configured for queue")

+ func Exec(ctx context.Context, handler Handler) (err error)

+ func JobFromContext(ctx context.Context) (*jobs.Job, error)

+ func WithContext(ctx context.Context, v CtxVars) context.Context

+ type CtxVars struct

+ Job *jobs.Job

+ Tx any

+ type Func func(ctx context.Context) error

+ type Handler struct

+ Concurrency int

+ Deadline time.Duration

+ Handle Func

+ QueueCapacity int64

+ func New(f Func, opts ...Option) (h Handler)

+ func (h *Handler) WithOptions(opts ...Option)

+ type Option func(w *Handler)

+ func Concurrency(c int) Option

+ func Deadline(d time.Duration) Option

+ func MaxQueueCapacity(capacity int64) Option