Versions in this module Expand all Collapse all v4 v4.3.2 Mar 8, 2023 Changes in this version + const ConnCloseType + const ConsumeCloseType + const PublishCloseType + const StatCloseType + type Configurer interface + Has func(name string) bool + UnmarshalKey func(name string, out any) error + type Driver struct + func FromConfig(configKey string, log *zap.Logger, cfg Configurer, pipeline jobs.Pipeline, ...) (*Driver, error) + func FromPipeline(pipeline jobs.Pipeline, log *zap.Logger, cfg Configurer, pq pq.Queue, ...) (*Driver, error) + func (d *Driver) Pause(_ context.Context, p string) error + func (d *Driver) Push(ctx context.Context, job jobs.Job) error + func (d *Driver) Resume(_ context.Context, p string) error + func (d *Driver) Run(_ context.Context, p jobs.Pipeline) error + func (d *Driver) State(ctx context.Context) (*jobs.State, error) + func (d *Driver) Stop(context.Context) error + type Item struct + Headers map[string][]string + Ident string + Job string + Options *Options + Payload string + func (i *Item) Ack() error + func (i *Item) Body() []byte + func (i *Item) Context() ([]byte, error) + func (i *Item) ID() string + func (i *Item) Nack() error + func (i *Item) Priority() int64 + func (i *Item) Requeue(headers map[string][]string, delay int64) error + func (i *Item) Respond(_ []byte, _ string) error + type Options struct + AutoAck bool + Delay int64 + Pipeline string + Priority int64 + func (o *Options) DelayDuration() time.Duration Other modules containing this package github.com/willypuzzle/amqp/v3
Go to main page