retry

Documentation

Index

• Constants
• type DecorRelatedJitter
  • func NewDecorRelatedJitter() *DecorRelatedJitter
  • func (d *DecorRelatedJitter) ComputeDelayBeforeNextRetry(int32) int32
  • func (s DecorRelatedJitter) GetBaseDelay() int32
  • func (s DecorRelatedJitter) SetBaseDelay(baseDelay int32)
• type EqualJitter
  • func NewEqualJitter() *EqualJitter
  • func (e *EqualJitter) ComputeDelayBeforeNextRetry(retryTimes int32) int32
  • func (s EqualJitter) GetBaseDelay() int32
  • func (s EqualJitter) SetBaseDelay(baseDelay int32)
• type Exponential
  • func NewExponential() *Exponential
  • func (e *Exponential) ComputeDelayBeforeNextRetry(retryTimes int32) int32
  • func (s Exponential) GetBaseDelay() int32
  • func (s Exponential) SetBaseDelay(baseDelay int32)
• type None
  • func (n None) ComputeDelayBeforeNextRetry(int32) int32
  • func (n None) SetBaseDelay(int32)
• type RandomJitter
  • func NewRandomJitter() *RandomJitter
  • func (r *RandomJitter) ComputeDelayBeforeNextRetry(retryTimes int32) int32
  • func (s RandomJitter) GetBaseDelay() int32
  • func (s RandomJitter) SetBaseDelay(baseDelay int32)
• type Strategy

Constants

const (
	BaseDelay = 10        // base delay is 10ms
	MaxDelay  = 60 * 1000 // max delay is 60s
)

Types

type DecorRelatedJitter

type DecorRelatedJitter struct {
	// contains filtered or unexported fields
}

DecorRelatedJitter 去相关抖动退避 delay = min(最大等待时间, random(基础等待时间, 基础等待时间 * 3);

func NewDecorRelatedJitter

func NewDecorRelatedJitter() *DecorRelatedJitter

func (*DecorRelatedJitter) ComputeDelayBeforeNextRetry

func (d *DecorRelatedJitter) ComputeDelayBeforeNextRetry(int32) int32

func (DecorRelatedJitter) GetBaseDelay

func (s DecorRelatedJitter) GetBaseDelay() int32

func (DecorRelatedJitter) SetBaseDelay

func (s DecorRelatedJitter) SetBaseDelay(baseDelay int32)

type EqualJitter

type EqualJitter struct {
	// contains filtered or unexported fields
}

EqualJitter 等抖动指数退避 delay = Exponential/2 + random(0, Exponential/2)

func NewEqualJitter

func NewEqualJitter() *EqualJitter

func (*EqualJitter) ComputeDelayBeforeNextRetry

func (e *EqualJitter) ComputeDelayBeforeNextRetry(retryTimes int32) int32

func (EqualJitter) GetBaseDelay

func (s EqualJitter) GetBaseDelay() int32

func (EqualJitter) SetBaseDelay

func (s EqualJitter) SetBaseDelay(baseDelay int32)

type Exponential

type Exponential struct {
	// contains filtered or unexported fields
}

Exponential 指数退避 delay = min(最大等待时间, 基础等待时间 * (2^已重试次数))

func NewExponential

func NewExponential() *Exponential

func (*Exponential) ComputeDelayBeforeNextRetry

func (e *Exponential) ComputeDelayBeforeNextRetry(retryTimes int32) int32

func (Exponential) GetBaseDelay

func (s Exponential) GetBaseDelay() int32

func (Exponential) SetBaseDelay

func (s Exponential) SetBaseDelay(baseDelay int32)

type None

type None struct{}

func (None) ComputeDelayBeforeNextRetry

func (n None) ComputeDelayBeforeNextRetry(int32) int32

func (None) SetBaseDelay

func (n None) SetBaseDelay(int32)

type RandomJitter

type RandomJitter struct {
	// contains filtered or unexported fields
}

RandomJitter 全抖动指数退避 delay = random(0, Exponential)

func NewRandomJitter

func NewRandomJitter() *RandomJitter

func (*RandomJitter) ComputeDelayBeforeNextRetry

func (r *RandomJitter) ComputeDelayBeforeNextRetry(retryTimes int32) int32

func (RandomJitter) GetBaseDelay

func (s RandomJitter) GetBaseDelay() int32

func (RandomJitter) SetBaseDelay

func (s RandomJitter) SetBaseDelay(baseDelay int32)

type Strategy

type Strategy interface {
	SetBaseDelay(int32)
	ComputeDelayBeforeNextRetry(int32) int32
}