Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewRetryingProcessor ¶
func NewRetryingProcessor(f metrics.Factory, processor processor.MetricProcessor, opts ...RetryOption) processor.MetricProcessor
NewRetryingProcessor returns a processor that retries failures using an exponential backoff with jitter.
Types ¶
type RetryOption ¶
type RetryOption func(*retryOptions)
RetryOption allows setting options for exponential backoff retried
func MaxAttempts ¶
func MaxAttempts(attempts uint) RetryOption
MaxAttempts sets the maximum number of attempts to retry
func MaxBackoffInterval ¶
func MaxBackoffInterval(t time.Duration) RetryOption
MaxBackoffInterval sets the maximum backoff interval
func MinBackoffInterval ¶
func MinBackoffInterval(t time.Duration) RetryOption
MinBackoffInterval sets the minimum backoff interval
func PropagateError ¶
func PropagateError(b bool) RetryOption
PropagateError sets whether to propagate errors when retries are exhausted
Source Files
Click to show internal directories.
Click to hide internal directories.