package topic

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/topic"

Index

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
}

Source Files

configs.go convertors.go retriable_error.go

Directories

PathSynopsis
internal/topic/topicclientinternal
internal/topic/topicreaderinternal
internal/topic/topicwriterinternal
Version
v3.61.0
Published
Mar 26, 2024
Platform
js/wasm
Imports
11 packages
Last checked
2 minutes ago –

Tools for package owners.