runtime_retry

Documentation

Index

• func AlwaysTry(err error) bool
• func GetTryCount(ctx context.Context) int64
• func SetTryCount(ctx context.Context, trycount int64) context.Context
• func Stopped() error
• func WithAbsorbError(absorb bool) runtime.Configuration[*Retry]
• func WithAttempts(attempts uint) runtime.Configuration[*Retry]
• func WithDelay(delay time.Duration) runtime.Configuration[*Retry]
• func WithMaxDelay(delay time.Duration) runtime.Configuration[*Retry]
• func WithRetryOption(options ...retry.Option) runtime.Configuration[*Retry]
• type Retry
  • func NewRetry(configurations ...runtime.Configuration[*Retry]) *Retry
  • func (c *Retry) Do(fnToDo func(int64) error) error
  • func (c *Retry) Start() error
  • func (c *Retry) Stop()

Functions

func AlwaysTry

func AlwaysTry(err error) bool

func GetTryCount

func GetTryCount(ctx context.Context) int64

func SetTryCount

func SetTryCount(ctx context.Context, trycount int64) context.Context

func Stopped

func Stopped() error

func WithAbsorbError

func WithAbsorbError(absorb bool) runtime.Configuration[*Retry]

func WithAttempts

func WithAttempts(attempts uint) runtime.Configuration[*Retry]

func WithDelay

func WithDelay(delay time.Duration) runtime.Configuration[*Retry]

func WithMaxDelay

func WithMaxDelay(delay time.Duration) runtime.Configuration[*Retry]

func WithRetryOption

func WithRetryOption(options ...retry.Option) runtime.Configuration[*Retry]

configurations

Types

type Retry

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

implementation

func NewRetry

func NewRetry(configurations ...runtime.Configuration[*Retry]) *Retry

constructor

func (*Retry) Do

func (c *Retry) Do(fnToDo func(int64) error) error

func (*Retry) Start

func (c *Retry) Start() error

func (*Retry) Stop

func (c *Retry) Stop()