middleware

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

type OnRetryHook func(retryNum int, delay time.Duration)

type PoisonQueue struct {
	Middleware message.HandlerMiddleware
	// contains filtered or unexported fields
}

type RecoveredPanicError struct {
	V          interface{}
	Stacktrace string
}

type Retry struct {
	MaxRetries int

	WaitTime time.Duration
	Backoff  int64

	MaxDelay time.Duration

	OnRetryHook OnRetryHook

	Logger watermill.LoggerAdapter
}

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