Versions in this module Expand all Collapse all v1 v1.0.0 Aug 26, 2026 Changes in this version + var ErrConflict = idempotencyqueue.ErrConflict + var ErrInProgress = idempotencyqueue.ErrInProgress + var ErrTerminalFailure = idempotencyqueue.ErrTerminalFailure + func Wrap[D Delivery](processor *Processor, next func(context.Context, D) error) func(context.Context, D) error + type Delivery interface + Payload func() []byte + type FingerprintFunc func(Delivery) (idempotency.Fingerprint, error) + type Handler func(context.Context, Delivery) error + type KeyFunc func(context.Context, Delivery) (idempotency.Key, error) + type Options struct + Fingerprint FingerprintFunc + Key KeyFunc + Lease time.Duration + Service *idempotency.Service + TransitionTimeout time.Duration + type Processor struct + func New(options Options) (*Processor, error) + func (p *Processor) Handle(ctx context.Context, delivery Delivery, handler Handler) error
Go to main page