time

Documentation

Index

• Constants
• type EmptyExponentialBackOffOption
• type ExponentialBackOff
  • func NewExponentialBackOff(opts ...ExponentialBackOffOption) *ExponentialBackOff
  • func (o *ExponentialBackOff) ApplyOptions(options ...ExponentialBackOffOption) *ExponentialBackOff
  • func (b *ExponentialBackOff) GetCurrentInterval() time.Duration
  • func (b *ExponentialBackOff) GetElapsedTime() time.Duration
  • func (b *ExponentialBackOff) NextBackOff() (time.Duration, bool)
  • func (b *ExponentialBackOff) Reset()
• type ExponentialBackOffOption
  • func WithExponentialBackOffOptionInitialInterval(initialInterval time.Duration) ExponentialBackOffOption
  • func WithExponentialBackOffOptionMaxElapsedTime(maxElapsedTime time.Duration) ExponentialBackOffOption
  • func WithExponentialBackOffOptionMaxInterval(maxInterval time.Duration) ExponentialBackOffOption
  • func WithExponentialBackOffOptionMultiplier(multiplier float64) ExponentialBackOffOption
  • func WithExponentialBackOffOptionRandomizationFactor(randomizationFactor float64) ExponentialBackOffOption
• type ExponentialBackOffOptionFunc
• type TimeCounter
  • func New(effect bool) *TimeCounter
  • func (t *TimeCounter) Reset()
  • func (t *TimeCounter) String() string
  • func (t *TimeCounter) Summary(f func(idx int, msg string, cost time.Duration, at time.Time))
  • func (t *TimeCounter) Tick(msg string)

Constants

const (
	DefaultInitialInterval     = 500 * time.Millisecond
	DefaultRandomizationFactor = 0.5
	// The default multiplier value used for increment current interval
	DefaultMultiplier     = 1.5
	DefaultMaxInterval    = 60 * time.Second
	DefaultMaxElapsedTime = 15 * time.Minute
)

Default values for ExponentialBackOff.

Types

type EmptyExponentialBackOffOption

type EmptyExponentialBackOffOption struct{}

EmptyExponentialBackOffUrlOption does not alter the ExponentialBackOffuration. It can be embedded in another structure to build custom options.

This API is EXPERIMENTAL.

type ExponentialBackOff

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

func NewExponentialBackOff

func NewExponentialBackOff(opts ...ExponentialBackOffOption) *ExponentialBackOff

func (*ExponentialBackOff) ApplyOptions

func (o *ExponentialBackOff) ApplyOptions(options ...ExponentialBackOffOption) *ExponentialBackOff

func (*ExponentialBackOff) GetCurrentInterval

func (b *ExponentialBackOff) GetCurrentInterval() time.Duration

func (*ExponentialBackOff) GetElapsedTime

func (b *ExponentialBackOff) GetElapsedTime() time.Duration

func (*ExponentialBackOff) NextBackOff

func (b *ExponentialBackOff) NextBackOff() (time.Duration, bool)

false : have gone over the maximu elapsed time true : return remaining time

func (*ExponentialBackOff) Reset

func (b *ExponentialBackOff) Reset()

type ExponentialBackOffOption

type ExponentialBackOffOption interface {
	// contains filtered or unexported methods
}

A ExponentialBackOffOption sets options.

func WithExponentialBackOffOptionInitialInterval

func WithExponentialBackOffOptionInitialInterval(initialInterval time.Duration) ExponentialBackOffOption

func WithExponentialBackOffOptionMaxElapsedTime

func WithExponentialBackOffOptionMaxElapsedTime(maxElapsedTime time.Duration) ExponentialBackOffOption

func WithExponentialBackOffOptionMaxInterval

func WithExponentialBackOffOptionMaxInterval(maxInterval time.Duration) ExponentialBackOffOption

func WithExponentialBackOffOptionMultiplier

func WithExponentialBackOffOptionMultiplier(multiplier float64) ExponentialBackOffOption

func WithExponentialBackOffOptionRandomizationFactor

func WithExponentialBackOffOptionRandomizationFactor(randomizationFactor float64) ExponentialBackOffOption

type ExponentialBackOffOptionFunc

type ExponentialBackOffOptionFunc func(*ExponentialBackOff)

ExponentialBackOffOptionFunc wraps a function that modifies ExponentialBackOff into an implementation of the ExponentialBackOffOption interface.

type TimeCounter

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

func New

func New(effect bool) *TimeCounter

func (*TimeCounter) Reset

func (t *TimeCounter) Reset()

func (*TimeCounter) String

func (t *TimeCounter) String() string

func (*TimeCounter) Summary

func (t *TimeCounter) Summary(f func(idx int, msg string, cost time.Duration, at time.Time))

func (*TimeCounter) Tick

func (t *TimeCounter) Tick(msg string)