topic

Documentation

Index

• Constants
• Variables
• func CheckResetReconnectionCounters(lastTry, now time.Time, connectionTimeout time.Duration) bool
• func CheckRetryMode(err error, settings RetrySettings, retriesDuration time.Duration) (_ backoff.Backoff, isRetriable bool)
• func OperationParamsFromConfig(operationParams *rawydb.OperationParams, cfg *config.Common)
• type Config
• type PublicCheckErrorRetryArgs
  • func NewCheckRetryArgs(err error) PublicCheckErrorRetryArgs
• type PublicCheckErrorRetryFunction
• type PublicCheckRetryResult
• type RetrySettings

Constants

const (
	DefaultStartTimeout = time.Minute
)

Variables

var (
	PublicRetryDecisionDefault = PublicCheckRetryResult{/* contains filtered or unexported fields */}
	PublicRetryDecisionRetry   = PublicCheckRetryResult{/* contains filtered or unexported fields */}
	PublicRetryDecisionStop    = PublicCheckRetryResult{/* contains filtered or unexported fields */}
)

Functions

func CheckResetReconnectionCounters

func CheckResetReconnectionCounters(lastTry, now time.Time, connectionTimeout time.Duration) bool

func CheckRetryMode

func CheckRetryMode(err error, settings RetrySettings, retriesDuration time.Duration) (
	_ backoff.Backoff,
	isRetriable bool,
)

func OperationParamsFromConfig

func OperationParamsFromConfig(operationParams *rawydb.OperationParams, cfg *config.Common)

Types

type Config

type Config struct {
	config.Common
	Trace *trace.Topic
}

type PublicCheckErrorRetryArgs

type PublicCheckErrorRetryArgs struct {
	Error error
}

func NewCheckRetryArgs

func NewCheckRetryArgs(err error) PublicCheckErrorRetryArgs

type PublicCheckErrorRetryFunction

type PublicCheckErrorRetryFunction func(errInfo PublicCheckErrorRetryArgs) PublicCheckRetryResult

type PublicCheckRetryResult

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

type RetrySettings

type RetrySettings struct {
	StartTimeout time.Duration // Full retry timeout
	CheckError   PublicCheckErrorRetryFunction
}