Versions in this module Expand all Collapse all v2 v2.6.0 Apr 26, 2021 Changes in this version + const BackoffStrategyConstant + const BackoffStrategyExponential + const BackoffStrategyLinear + const BackoffStrategyNone + var DefaultRetryParams = RetryParams + func LoggerFrom(ctx context.Context) *zap.SugaredLogger + func TargetFrom(ctx context.Context) *url.URL + func TopicFrom(ctx context.Context) string + func WithLogger(ctx context.Context, logger *zap.SugaredLogger) context.Context + func WithRetriesConstantBackoff(ctx context.Context, delay time.Duration, maxTries int) context.Context + func WithRetriesExponentialBackoff(ctx context.Context, period time.Duration, maxTries int) context.Context + func WithRetriesLinearBackoff(ctx context.Context, delay time.Duration, maxTries int) context.Context + func WithRetryParams(ctx context.Context, rp *RetryParams) context.Context + func WithTarget(ctx context.Context, target string) context.Context + func WithTopic(ctx context.Context, topic string) context.Context + type BackoffStrategy string + type RetryParams struct + MaxTries int + Period time.Duration + Strategy BackoffStrategy + func RetriesFrom(ctx context.Context) *RetryParams + func (r *RetryParams) Backoff(ctx context.Context, tries int) error + func (r *RetryParams) BackoffFor(tries int) time.Duration