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 Option
- type PublicCheckErrorRetryArgs
- type PublicCheckErrorRetryFunction
- type PublicCheckRetryResult
- type RetrySettings
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:mnd )
Functions ¶
func CheckResetReconnectionCounters ¶ added in v3.42.0
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 Option ¶ added in v3.101.3
type Option func(c *Config)
func PublicWithOperationCancelAfter ¶ added in v3.101.3
func PublicWithOperationTimeout ¶ added in v3.101.3
func PublicWithTrace ¶ added in v3.101.3
func PublicWithTrace(trace trace.Topic, opts ...trace.TopicComposeOption) Option
func WithGrpcMessageSize ¶ added in v3.101.3
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
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.