boltjobs

Jul 3, 2024

Changes in this version

+ const DelayBucket

+ const InQueueBucket

+ const PushBucket

+ type Configurer interface

+ Has func(name string) bool

+ UnmarshalKey func(name string, out any) error

+ type Driver struct

+ func FromConfig(tracer *sdktrace.TracerProvider, configKey string, log *zap.Logger, ...) (*Driver, error)

+ func FromPipeline(tracer *sdktrace.TracerProvider, pipeline jobs.Pipeline, log *zap.Logger, ...) (*Driver, error)

+ func (d *Driver) Pause(ctx context.Context, p string) error

+ func (d *Driver) Push(ctx context.Context, job jobs.Message) error

+ func (d *Driver) Resume(ctx context.Context, p string) error

+ func (d *Driver) Run(ctx context.Context, p jobs.Pipeline) error

+ func (d *Driver) State(ctx context.Context) (*jobs.State, error)

+ func (d *Driver) Stop(ctx context.Context) error

+ type Item struct

+ Ident string

+ Job string

+ Options *Options

+ Payload []byte

+ func (i *Item) Ack() error

+ func (i *Item) Body() []byte

+ func (i *Item) Context() ([]byte, error)

+ func (i *Item) GroupID() string

+ func (i *Item) Headers() map[string][]string

+ func (i *Item) ID() string

+ func (i *Item) Nack() error

+ func (i *Item) NackWithOptions(requeue bool, delay int) error

+ func (i *Item) Priority() int64

+ func (i *Item) Requeue(headers map[string][]string, delay int) error

+ func (i *Item) Respond(_ []byte, _ string) error

+ type Options struct

+ AutoAck bool

+ Delay int

+ Pipeline string

+ Priority int64

+ Queue string