retry

Documentation

Overview

Package retry handles retry operations.

Index

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

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(database string)
}

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
	// contains filtered or unexported fields
}

func (*State) Continue

func (s *State) Continue() bool

func (*State) OnFailure

func (s *State) OnFailure(conn db.Connection, err error, isCommitting bool)

type Throttler

type Throttler time.Duration