process

Oct 1, 2023

Changes in this version

+ type Batch struct

+ func InBatches(amount int, timeout time.Duration, tx BatchTransaction, rejectRequeue bool, ...) *Batch

+ func (c *Batch) Process(ctx context.Context, deliveries <-chan amqp.Delivery) error

+ type BatchDeliveryHandler func(context.Context, []amqp.Delivery) (status []error)

+ type BatchMiddleware func(BatchDeliveryHandler) BatchDeliveryHandler

+ type BatchTransaction func(context.Context, [][]byte) (status []error)

+ type DeliveryHandler func(context.Context, amqp.Delivery) error

+ type Middleware func(DeliveryHandler) DeliveryHandler

+ type One struct

+ func ByOne(tx Transaction, rejectRequeue bool, mws ...Middleware) *One

+ func (c *One) Process(ctx context.Context, deliveries <-chan amqp.Delivery) error

+ type Transaction func(context.Context, []byte) error