▽

Package backoff

Variables

DefaultExponential is an exponential backoff implementation using the default values for all the configurable knobs defined in https://github.com/grpc/grpc/blob/master/doc/connection-backoff.md.

var DefaultExponential = Exponential{Config: grpcbackoff.DefaultConfig}

ErrResetBackoff is the error to be returned by the function executed by RunF, to instruct the latter to reset its backoff state.

var ErrResetBackoff = errors.New("reset backoff state")

func RunF ¶

func RunF(ctx context.Context, f func() error, backoff func(int) time.Duration)

RunF provides a convenient way to run a function f repeatedly until the context expires or f returns a non-nil error that is not ErrResetBackoff. When f returns ErrResetBackoff, RunF continues to run f, but resets its backoff state before doing so. backoff accepts an integer representing the number of retries, and returns the amount of time to backoff.

type Exponential ¶

Exponential implements exponential backoff algorithm as defined in https://github.com/grpc/grpc/blob/master/doc/connection-backoff.md.

type Exponential struct {
    // Config contains all options to configure the backoff algorithm.
    Config grpcbackoff.Config
}

func (Exponential) Backoff ¶

func (bc Exponential) Backoff(retries int) time.Duration

Backoff returns the amount of time to wait before the next retry given the number of retries.

type Strategy ¶

Strategy defines the methodology for backing off after a grpc connection failure.

type Strategy interface {
    // Backoff returns the amount of time to wait before the next retry given
    // the number of consecutive failures.
    Backoff(retries int) time.Duration
}