throttle

Documentation

Overview

Package throttle implements throttle strategies.

Index

• func OptCloseChan(c <-chan struct{}) func(*Type)
• func OptMaxExponentPeriod(period time.Duration) func(*Type)
• func OptMaxUnthrottledRetries(n int64) func(*Type)
• func OptThrottlePeriod(period time.Duration) func(*Type)
• type Type
  • func New(options ...func(*Type)) *Type
  • func (t *Type) ExponentialRetry() bool
  • func (t *Type) Reset()
  • func (t *Type) Retry() bool

Functions

func OptCloseChan

func OptCloseChan(c <-chan struct{}) func(*Type)

OptCloseChan sets a read-only channel that, if closed, will interrupt a retry throttle early.

func OptMaxExponentPeriod

func OptMaxExponentPeriod(period time.Duration) func(*Type)

OptMaxExponentPeriod sets the maximum period of time that throttles will last when exponentially increasing.

func OptMaxUnthrottledRetries

func OptMaxUnthrottledRetries(n int64) func(*Type)

OptMaxUnthrottledRetries sets the maximum number of consecutive retries that will be attempted before throttling will begin.

func OptThrottlePeriod

func OptThrottlePeriod(period time.Duration) func(*Type)

OptThrottlePeriod sets the static period of time that throttles will last.

Types

type Type

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

Type is a throttle of retries to avoid endless busy loops when a message fails to reach its destination. This isn't intended to be used for hitting load balanced resources and therefore doesn't implement anything clever like exponential backoff.

func New

func New(options ...func(*Type)) *Type

New creates a new throttle, which permits a static number of consecutive retries before throttling subsequent retries. A success will reset the count of consecutive retries.

func (*Type) ExponentialRetry

func (t *Type) ExponentialRetry() bool

ExponentialRetry is the same as Retry except also sets the throttle period to exponentially increase after each consecutive retry.

func (*Type) Reset

func (t *Type) Reset()

Reset clears the count of consecutive retries and resets the exponential backoff.

func (*Type) Retry

func (t *Type) Retry() bool

Retry indicates that a retry is about to occur and, if appropriate, will block until either the throttle period is over and the retry may be attempted (returning true) or that the close channel has closed (returning false).