topic

package
v3.78.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 4, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultStartTimeout = value.InfiniteDuration
)

Variables

View Source
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 added in v3.42.0

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

func OperationParamsFromConfig

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

func RetryDecision added in v3.76.2

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 added in v3.42.0

type PublicCheckErrorRetryArgs struct {
	Error error
}

func NewCheckRetryArgs added in v3.42.0

func NewCheckRetryArgs(err error) PublicCheckErrorRetryArgs

type PublicCheckErrorRetryFunction added in v3.42.0

type PublicCheckErrorRetryFunction func(errInfo PublicCheckErrorRetryArgs) PublicCheckRetryResult

type PublicCheckRetryResult added in v3.42.0

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

type RetrySettings added in v3.42.0

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL