retry

Documentation

Index

• type Policy
  • func (p *Policy) NoJitter() *Policy
  • func (p *Policy) Run(fn func(attempt int) (err error, fatal error)) error

Types

type Policy

type Policy struct {
	MaxAttempts int
	Backoff     time.Duration
	Multiplier  float64
	MaxBackoff  time.Duration
	Jitter      time.Duration
	// contains filtered or unexported fields
}

func (*Policy) NoJitter

func (p *Policy) NoJitter() *Policy

func (*Policy) Run

func (p *Policy) Run(fn func(attempt int) (err error, fatal error)) error

Run executes fn using retry policy p. Stops retrying on success or after p.Attempts retries. In case fn returns fatal error, Run exits immediately. Note: use `policy.NoJitter().Run(...)` to eliminate jitter. Simple `policy := Policy{Jitter: 0}; policy.Run(...)` will result in default jitter.