backoff

Documentation

Index

• Variables
• type Policy
  • func (b Policy) Duration(n int) time.Duration
  • func (b Policy) For(ctx context.Context, cb func(try int) error) error
  • func (b Policy) Sleep(ctx context.Context, t time.Duration) error
  • func (b Policy) TrySleep(ctx context.Context, n int) error

Variables

var Default = FiveSec

Default is the default backoff policy to use

var FiveSec = Policy{
	Millis: []int{500, 750, 1000, 1500, 2000, 2500, 3000, 3500, 4000, 4500, 5000},
}

FiveSec is a backoff policy ranging up to 5 seconds.

var TwentySec = Policy{
	Millis: []int{
		500, 750, 1000, 1500, 2000, 2500, 3000, 3500, 4000, 4500, 5000,
		5500, 5750, 6000, 6500, 7000, 7500, 8000, 8500, 9000, 9500, 10000,
		10500, 10750, 11000, 11500, 12000, 12500, 13000, 13500, 14000, 14500, 15000,
		15500, 15750, 16000, 16500, 17000, 17500, 18000, 18500, 19000, 19500, 20000,
	},
}

TwentySec is a backoff policy ranging up to 20 seconds

Types

type Policy

type Policy struct {
	Millis []int
}

Policy implements a backoff policy, randomizing its delays and saturating at the final value in Millis.

func (Policy) Duration

func (b Policy) Duration(n int) time.Duration

Duration returns the time duration of the n'th wait cycle in a backoff policy. This is b.Millis[n], randomized to avoid thundering herds.

func (Policy) For

func (b Policy) For(ctx context.Context, cb func(try int) error) error

For is a for{} loop that stops on context and has a backoff based sleep between loops if the context completes the loop ends returning the context error

func (Policy) Sleep

func (b Policy) Sleep(ctx context.Context, t time.Duration) error

Sleep sleeps for the duration t and can be interrupted by ctx. An error is returns if the context cancels the sleep

func (Policy) TrySleep

func (b Policy) TrySleep(ctx context.Context, n int) error

TrySleep sleeps for the duration of the n'th try cycle in a way that can be interrupted by the context. An error is returned if the context cancels the sleep