Versions in this module Expand all Collapse all v0 v0.1.1 Nov 12, 2018 Changes in this version + const CorrelationIDMetadataKey + const RetryForever + var ErrInvalidPoisonQueueTopic = errors.New("invalid poison queue topic") + var ReasonForPoisonedKey = "reason_poisoned" + func CorrelationID(h message.HandlerFunc) message.HandlerFunc + func InstantAck(h message.HandlerFunc) message.HandlerFunc + func MessageCorrelationID(message *message.Message) string + func RandomFail(errorRatio float32) message.HandlerMiddleware + func RandomPanic(panicRatio float32) message.HandlerMiddleware + func Recoverer(h message.HandlerFunc) message.HandlerFunc + func SetCorrelationID(id string, msg *message.Message) + type IgnoreErrors struct + func NewIgnoreErrors(errs []error) IgnoreErrors + func (i IgnoreErrors) Middleware(h message.HandlerFunc) message.HandlerFunc + type Metrics struct + func NewMetrics(timer metrics.Timer, errs metrics.Counter, success metrics.Counter) Metrics + func (m Metrics) Middleware(h message.HandlerFunc) message.HandlerFunc + func (m Metrics) ShowStats(interval time.Duration, logger metrics.Logger) + type OnRetryHook func(retryNum int, delay time.Duration) + type PoisonQueue struct + Middleware message.HandlerMiddleware + func NewPoisonQueue(pub message.Publisher, topic string) (PoisonQueue, error) + type Retry struct + Backoff int64 + Logger watermill.LoggerAdapter + MaxDelay time.Duration + MaxRetries int + OnRetryHook OnRetryHook + WaitTime time.Duration + func (r Retry) Middleware(h message.HandlerFunc) message.HandlerFunc + type Throttle struct + func NewThrottlePerSecond(perSecond int, logger watermill.LoggerAdapter) (Throttle, error) + func (t Throttle) Middleware(h message.HandlerFunc) message.HandlerFunc v0.1.0 Nov 12, 2018