retry

Documentation

Index

• type ExpRetry
  • func NewExpRetry(maxRetries int, baseMultiplier int, minDelay time.Duration, ...) *ExpRetry
  • func (r *ExpRetry) Iterator() *ExpRetryIterator
• type ExpRetryConfig
  • func DefaultExpRetryConfig() *ExpRetryConfig
• type ExpRetryIterator
  • func (i *ExpRetryIterator) HasNext() bool
  • func (i *ExpRetryIterator) WaitNext(ctx context.Context) error

Types

type ExpRetry

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

ExpRetry increase wait time exponentially with try number (delay = minDelay * baseMultiplier ^ attempt)

func NewExpRetry

func NewExpRetry(maxRetries int, baseMultiplier int, minDelay time.Duration, maxDelay *time.Duration) *ExpRetry

func (*ExpRetry) Iterator

func (r *ExpRetry) Iterator() *ExpRetryIterator

type ExpRetryConfig

type ExpRetryConfig struct {
	MaxRetries     int              `yaml:"max_retries,omitempty" json:"max_retries"`
	BaseMultiplier int              `yaml:"base_multiplier,omitempty" json:"base_multiplier"`
	MinDelay       fields.Duration  `yaml:"min_delay,omitempty" json:"min_delay" swaggertype:"primitive,string"`
	MaxDelay       *fields.Duration `yaml:"max_delay,omitempty" json:"max_delay" swaggertype:"primitive,string"`
}

func DefaultExpRetryConfig

func DefaultExpRetryConfig() *ExpRetryConfig

type ExpRetryIterator

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

func (*ExpRetryIterator) HasNext

func (i *ExpRetryIterator) HasNext() bool

func (*ExpRetryIterator) WaitNext

func (i *ExpRetryIterator) WaitNext(ctx context.Context) error