retry

Documentation

Overview

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

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

Index

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

Functions

func Retry

func Retry(logger log.T, attempts int, sleep time.Duration, fn func() error) 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
}

RepeatableExponentialRetryer implements exponential backoff retry strategy.

func (*RepeatableExponentialRetryer) Call

func (r *RepeatableExponentialRetryer) Call() error

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

func (*RepeatableExponentialRetryer) NextSleepTime

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

NextSleepTime calculates the next delay of retry.

type Retryer

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

Retryer defines the interface for retry operations.