topic

Documentation

Index

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

Constants

const (
	DefaultStartTimeout = value.InfiniteDuration
)

Variables

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

Functions

func CheckResetReconnectionCounters

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

func OperationParamsFromConfig

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

func RetryDecision

func RetryDecision(checkErr error, settings RetrySettings, retriesDuration time.Duration) (
	_ backoff.Backoff,
	stopRetryReason error,
)

RetryDecision check if err is retriable. if return nil stopRetryReason - err can be retried if return non nil stopRetryReason - err is not retriable and stopRetryReason contains reason, which should be used instead of err

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
}