retry

Documentation

Overview

Package retry handles retry operations.

Index

• func IsRetryable(err error) bool
• type CommitFailedDeadError
  • func (e *CommitFailedDeadError) Error() string
• type Router
• type State
  • func (s *State) Continue() bool
  • func (s *State) OnFailure(ctx context.Context, conn idb.Connection, err error, isCommitting bool)
• type Throttler

Functions

func IsRetryable

func IsRetryable(err error) bool

Types

type CommitFailedDeadError

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

func (*CommitFailedDeadError) Error

func (e *CommitFailedDeadError) Error() string

type Router

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

type State

type State struct {
	LastErrWasRetryable bool
	LastErr             error

	Errs                    []error
	Causes                  []string
	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, conn idb.Connection, err error, isCommitting bool)

type Throttler

type Throttler time.Duration