util

Documentation

Index

• func SwapTimeouts(newTimeouts []time.Duration) (oldTimeouts []time.Duration)
• func Timeouts() []time.Duration
• type AutoRedialer
  • func NewAutoRedialer(dialer Dialer) AutoRedialer
• type Dialer
• type Jitterer

Functions

func SwapTimeouts

func SwapTimeouts(newTimeouts []time.Duration) (oldTimeouts []time.Duration)

for testing: change the default timeouts for the provided ones, returning the defaults (the idea being you reset them on test teardown)

func Timeouts

func Timeouts() []time.Duration

retrieve the list of timeouts used for exponential backoff

Types

type AutoRedialer

type AutoRedialer interface {
	Redial() uint32 // Redial keeps on calling Dial until it stops returning an error.
	Stop()          // Stop shuts down the given AutoRedialer, if it is still retrying.
}

An AutoRedialer's Redial() method retries its dialer's Dial() method until it stops returning an error. It does exponential (optionally jitter'ed) backoff.

func NewAutoRedialer

func NewAutoRedialer(dialer Dialer) AutoRedialer

returns a stoppable AutoRedialer using the provided Dialer. If the Dialer is also a Jitterer, the backoff will be jittered.

type Dialer

type Dialer interface {
	Dial() error
}

A Dialer is an object that knows how to establish a connection, and where you'd usually want some kind of back off if that connection fails.

type Jitterer

type Jitterer interface {
	Dialer
	Jitter(time.Duration) time.Duration
}

A Jitterer is a Dialer that wants to vary the backoff a little (to avoid a thundering herd, for example).