retry

Documentation

Overview

retry implements back off retry strategy for reconnect web socket connection.

retry implements back off retry strategy for reconnect web socket connection.

Index

• func Retry(log log.T, attempts int, sleep time.Duration, fn func() error) (err error)
• type RepeatableExponentialRetryer
  • func (retryer *RepeatableExponentialRetryer) Call() (err error)
  • func (retryer *RepeatableExponentialRetryer) NextSleepTime(attempt int) time.Duration
• type Retryer

Functions

func Retry

func Retry(log log.T, attempts int, sleep time.Duration, fn func() error) (err error)

Retry implements back off retry strategy for reconnect web socket connection.

Types

type RepeatableExponentialRetryer

type RepeatableExponentialRetryer struct {
	CallableFunc        func() error
	GeometricRatio      float64
	InitialDelayInMilli int
	MaxDelayInMilli     int
	MaxAttempts         int
}

func (*RepeatableExponentialRetryer) Call

func (retryer *RepeatableExponentialRetryer) Call() (err error)

Call calls the operation and does exponential retry if error happens.

func (*RepeatableExponentialRetryer) NextSleepTime

func (retryer *RepeatableExponentialRetryer) NextSleepTime(attempt int) time.Duration

NextSleepTime calculates the next delay of retry.

type Retryer

type Retryer interface {
	Call() error
	NextSleepTime(int32) time.Duration
}