retry

Documentation

Overview

Package retry handles retry operations.

Index

• func IsRetryable(err error) bool
• type Router
• type State
  • func (s *State) Continue() bool
  • func (s *State) OnFailure(ctx 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 Router

type Router interface {
	Invalidate(ctx context.Context, database string) error
}

type State

type State struct {
	Errs                    []error
	MaxTransactionRetryTime time.Duration
	Log                     log.Logger
	LogName                 string
	LogId                   string
	Now                     *func() time.Time
	Sleep                   func(time.Duration)
	Throttle                Throttler
	MaxDeadConnections      int
	Router                  Router
	DatabaseName            string

	OnDeadConnection func(server string) error
	// contains filtered or unexported fields
}

func (*State) Continue

func (s *State) Continue() bool

func (*State) OnFailure

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

func (*State) ProduceError

func (s *State) ProduceError() error

type Throttler

type Throttler time.Duration