retry

Documentation

Overview

Package retry handles retry operations.

Index

• func IsRetryable(err error) bool
• type State
  • func (s *State) Continue(ctx context.Context) bool
  • func (s *State) OnFailure(_ context.Context, err error, conn idb.Connection, isCommitting bool)
  • func (s *State) ProduceError() error
• type Throttler

Functions

func IsRetryable

func IsRetryable(err error) bool

Types

type State

type State struct {
	Errs                    []error
	MaxTransactionRetryTime time.Duration
	Log                     log.Logger
	LogName                 string
	LogId                   string
	Sleep                   func(context.Context, time.Duration) error
	Throttle                Throttler
	MaxDeadConnections      int
	DatabaseName            string
	TelemetrySent           bool
	// contains filtered or unexported fields
}

func (*State) Continue

func (s *State) Continue(ctx context.Context) bool

func (*State) OnFailure

func (s *State) OnFailure(_ context.Context, err error, conn idb.Connection, isCommitting bool)

func (*State) ProduceError

func (s *State) ProduceError() error

type Throttler

type Throttler time.Duration