Versions in this module Expand all Collapse all v0 v0.2.4 Feb 25, 2021 Changes in this version + func Run(ctx context.Context, stream <-chan Job, opts ...Option) error + type Job struct + Ack func(err error) + Error error + ID string + Payload interface{} + Time time.Time + func (j *Job) EnsureValid() error + func (j Job) String() string + type Option func(ws *workerSession) error + func WithLogger(lg log.Logger) Option + func WithProc(proc Proc, workerCount int) Option + type Proc interface + Exec func(ctx context.Context, job Job) error + type ProcFn func(ctx context.Context, job Job) error + func (pFn ProcFn) Exec(ctx context.Context, job Job) error + type Stream func(ctx context.Context) (<-chan Job, error) + func StreamFn(buffer int, fn func(ctx context.Context) (*Job, error)) Stream
Go to main page