backoffs

package

v0.2.4 Latest Latest Go to latest Published: Mar 12, 2018 License: MIT Imports: 2 Imported by: 0

Details

View Source

const (
	TypeConstant    = "constant"
	TypeLinear      = "linear"
	TypeExponential = "exponential"
)

View Source

const DefaultInterval = 10

View Source

const DefaultMultiplier = 2

This section is empty.

This section is empty.

type Backoff interface {
	Init() time.Duration
	Next(failCount int) time.Duration
}

func New(cfg Config) Backoff

Creates new Backoff instance based on provided configuration

type Config struct {
	Type       string `json:"type"`
	Interval   *int   `json:"interval"`
	Multiplier *int   `json:"multiplier,omitempty"`
}

type Constant struct {
	Interval int
}

func NewConstant(interval int) *Constant

Constant backoff has always the same interval

func (b *Constant) Init() time.Duration

Returns initial interval

func (b *Constant) Next(failCount int) time.Duration

Returns next interval based on failed requests count

type Exponential struct {
	Interval   int
	Multiplier int
}

func NewExponential(interval int, multiplier *int) *Exponential

Exponential backoff provides a backoff implementation where the next delay upon failure is a multiplier of the previous delay

func (b *Exponential) Init() time.Duration

Returns initial interval

func (b *Exponential) Next(failCountInt int) time.Duration

Returns next interval based on failed requests count

type Linear struct {
	Interval int
}

func NewLinear(interval int) *Linear

Linear backoff multiplies initial interval by failed request count

func (b *Linear) Init() time.Duration

Returns initial interval

func (b *Linear) Next(failCount int) time.Duration

Returns next interval based on failed requests count