worker

type Options struct {
	Concurrency  int
	PollInterval time.Duration
	Lease        time.Duration
	Backoff      core.BackoffConfig
	Metrics      Recorder
	// DrainTimeout bounds how long Run waits for in-flight deliveries to finish
	// after the context is cancelled before force-cancelling them.
	DrainTimeout time.Duration
}

type Recorder interface {
	RecordDelivery(outcome string)
	RecordDeadLetter()
}

type Worker struct {
	// contains filtered or unexported fields
}