beanstalkjobs

Oct 22, 2021

Changes in this version

+ func FromPipeline(pipe *pipeline.Pipeline, log logger.Logger, cfg cfgPlugin.Configurer, ...) (*consumer, error)

+ func NewBeanstalkConsumer(configKey string, log logger.Logger, cfg cfgPlugin.Configurer, ...) (*consumer, error)

+ type ConnPool struct

+ func NewConnPool(network, address, tName string, tout time.Duration, log logger.Logger) (*ConnPool, error)

+ func (cp *ConnPool) Delete(_ context.Context, id uint64) error

+ func (cp *ConnPool) Put(_ context.Context, body []byte, pri uint32, delay, ttr time.Duration) (uint64, error)

+ func (cp *ConnPool) Reserve(reserveTimeout time.Duration) (uint64, []byte, error)

+ func (cp *ConnPool) Stats(_ context.Context) (map[string]string, error)

+ func (cp *ConnPool) Stop()

+ 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(data []byte, queue string) error

+ type Options struct

+ Delay int64

+ Pipeline string

+ Priority int64

+ func (o *Options) DelayDuration() time.Duration