configretry

Documentation

Index

• type BackOffConfig
  • func NewDefaultBackOffConfig() BackOffConfig
  • func (bs *BackOffConfig) Validate() error

Types

type BackOffConfig

type BackOffConfig struct {
	// Enabled indicates whether to not retry sending batches in case of export failure.
	Enabled bool `mapstructure:"enabled"`
	// InitialInterval the time to wait after the first failure before retrying.
	InitialInterval time.Duration `mapstructure:"initial_interval"`
	// RandomizationFactor is a random factor used to calculate next backoffs
	// Randomized interval = RetryInterval * (1 ± RandomizationFactor)
	RandomizationFactor float64 `mapstructure:"randomization_factor"`
	// Multiplier is the value multiplied by the backoff interval bounds
	Multiplier float64 `mapstructure:"multiplier"`
	// MaxInterval is the upper bound on backoff interval. Once this value is reached the delay between
	// consecutive retries will always be `MaxInterval`.
	MaxInterval time.Duration `mapstructure:"max_interval"`
	// MaxElapsedTime is the maximum amount of time (including retries) spent trying to send a request/batch.
	// Once this value is reached, the data is discarded. If set to 0, the retries are never stopped.
	MaxElapsedTime time.Duration `mapstructure:"max_elapsed_time"`
}

BackOffConfig defines configuration for retrying batches in case of export failure. The current supported strategy is exponential backoff.

func NewDefaultBackOffConfig

func NewDefaultBackOffConfig() BackOffConfig

NewDefaultBackOffConfig returns the default settings for RetryConfig.

func (*BackOffConfig) Validate

func (bs *BackOffConfig) Validate() error