v3 – github.com/ydb-platform/ydb-go-sdk/v3 Index | Files | Directories

package ydb

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

Index

Constants 

const (
	MetaRequestType = meta.HeaderRequestType
	MetaTraceID     = meta.HeaderTraceID
)
const (
	QUIET = Level(logger.QUIET)
	TRACE = Level(logger.TRACE)
	DEBUG = Level(logger.DEBUG)
	INFO  = Level(logger.INFO)
	WARN  = Level(logger.WARN)
	ERROR = Level(logger.ERROR)
	FATAL = Level(logger.FATAL)
)
const Version = meta.Version

Version alias for except cycle import

Functions

func IsOperationError 

func IsOperationError(err error) bool

func IsOperationErrorAlreadyExistsError 

func IsOperationErrorAlreadyExistsError(err error) bool

func IsOperationErrorCode 

func IsOperationErrorCode(err error, codes ...int32) bool

func IsOperationErrorNotFoundError 

func IsOperationErrorNotFoundError(err error) bool

func IsOperationErrorOverloaded 

func IsOperationErrorOverloaded(err error) bool

func IsOperationErrorSchemeError 

func IsOperationErrorSchemeError(err error) bool

func IsOperationErrorUnavailable 

func IsOperationErrorUnavailable(err error) bool

func IsRatelimiterAcquireError 

func IsRatelimiterAcquireError(err error) bool

func IsTimeoutError 

func IsTimeoutError(err error) bool

func IsTransportError 

func IsTransportError(err error) bool

func IsTransportErrorCancelled 

func IsTransportErrorCancelled(err error) bool

func IsTransportErrorCode 

func IsTransportErrorCode(err error, codes ...int32) bool

func IsTransportErrorResourceExhausted 

func IsTransportErrorResourceExhausted(err error) bool

func IsYdbError 

func IsYdbError(err error) bool

func IterateByIssues 

func IterateByIssues(err error, it func(message string, code uint32, severity uint32))

func RegisterParser 

func RegisterParser(param string, parser func(value string) ([]config.Option, error)) (err error)

func ToRatelimiterAcquireError 

func ToRatelimiterAcquireError(err error) ratelimiter.AcquireError

Types

type Connection 

type Connection interface {
	closer.Closer
	db.ConnectionInfo
	grpc.ClientConnInterface

	// Table returns table client with options from Connection instance.
	// Options provide options replacement for requested table client
	// such as database and access token
	Table(opts ...CustomOption) table.Client

	// Scheme returns scheme client with options from Connection instance.
	// Options provide options replacement for requested scheme client
	// such as database and access token
	Scheme(opts ...CustomOption) scheme.Client

	// Coordination returns coordination client with options from Connection instance.
	// Options provide options replacement for requested coordination client
	// such as database and access token
	Coordination(opts ...CustomOption) coordination.Client

	// Ratelimiter returns rate limiter client with options from Connection instance.
	// Options provide options replacement for requested rate limiter client
	// such as database and access token
	Ratelimiter(opts ...CustomOption) ratelimiter.Client

	// Discovery returns discovery client with options from Connection instance.
	// Options provide options replacement for requested discovery client
	// such as database and access token
	Discovery(opts ...CustomOption) discovery.Client

	// Scripting returns scripting client with options from Connection instance.
	// Options provide options replacement for requested scripting client
	// such as database and access token
	Scripting(opts ...CustomOption) scripting.Client

	// With returns Connection specified with custom options
	// Options provide options replacement for all clients taked from new Connection
	With(opts ...CustomOption) Connection
}

Connection interface provide access to YDB service clients Interface and list of clients may be changed in the future

func New 

func New(ctx context.Context, opts ...Option) (_ Connection, err error)

New connects to name and return name runtime holder

type CustomOption 

type CustomOption func(opts *customOptions)

func WithCustomCredentials 

func WithCustomCredentials(creds credentials.Credentials) CustomOption

func WithCustomDatabase 

func WithCustomDatabase(database string) CustomOption

func WithCustomToken 

func WithCustomToken(accessToken string) CustomOption

func WithCustomUserAgent 

func WithCustomUserAgent(userAgent string) CustomOption

type Error 

type Error interface {
	error

	Code() int32
	Name() string
}

func OperationErrorDescription 

func OperationErrorDescription(err error) Error

func TransportErrorDescription 

func TransportErrorDescription(err error) Error

type Level 

type Level logger.Level

type LoggerOption 

type LoggerOption logger.Option

func WithErrWriter 

func WithErrWriter(err io.Writer) LoggerOption

func WithExternalLogger 

func WithExternalLogger(external log.Logger) LoggerOption

func WithMinLevel 

func WithMinLevel(minLevel Level) LoggerOption

func WithNamespace 

func WithNamespace(namespace string) LoggerOption

func WithNoColor 

func WithNoColor(b bool) LoggerOption

func WithOutWriter 

func WithOutWriter(out io.Writer) LoggerOption

type Option 

type Option func(ctx context.Context, c *connection) error

func MergeOptions 

func MergeOptions(options ...Option) Option

func With 

func With(options ...config.Option) Option

func WithAccessTokenCredentials 

func WithAccessTokenCredentials(accessToken string) Option

func WithAnonymousCredentials 

func WithAnonymousCredentials() Option

func WithBalancer 

func WithBalancer(balancer balancer.Balancer) Option

func WithCertificate 

func WithCertificate(cert *x509.Certificate) Option

func WithCertificatesFromFile 

func WithCertificatesFromFile(caFile string) Option

func WithCertificatesFromPem 

func WithCertificatesFromPem(bytes []byte) Option

func WithConnectionString 

func WithConnectionString(connectionString string) Option

WithConnectionString accept connection string like 'grpc[s]://{endpoint}/?database={database}'

func WithConnectionTTL 

func WithConnectionTTL(ttl time.Duration) Option

func WithCreateCredentialsFunc 

func WithCreateCredentialsFunc(createCredentials func(ctx context.Context) (credentials.Credentials, error)) Option

func WithCredentials 

func WithCredentials(c credentials.Credentials) Option

func WithDatabase 

func WithDatabase(database string) Option

func WithDialTimeout 

func WithDialTimeout(timeout time.Duration) Option

func WithDiscoveryInterval 

func WithDiscoveryInterval(discoveryInterval time.Duration) Option

func WithEndpoint 

func WithEndpoint(endpoint string) Option

func WithInsecure 

func WithInsecure() Option

func WithLogger 

func WithLogger(details trace.Details, opts ...LoggerOption) Option

func WithMinTLSVersion 

func WithMinTLSVersion(minVersion uint16) Option

func WithRatelimiterOptions 

func WithRatelimiterOptions(opts ...ratelimiterConfig.Option) Option

func WithSecure 

func WithSecure(secure bool) Option

func WithSessionPoolCreateSessionTimeout 

func WithSessionPoolCreateSessionTimeout(createSessionTimeout time.Duration) Option

func WithSessionPoolDeleteTimeout 

func WithSessionPoolDeleteTimeout(deleteTimeout time.Duration) Option

func WithSessionPoolIdleThreshold 

func WithSessionPoolIdleThreshold(idleThreshold time.Duration) Option

func WithSessionPoolKeepAliveMinSize 

func WithSessionPoolKeepAliveMinSize(keepAliveMinSize int) Option

func WithSessionPoolKeepAliveTimeout 

func WithSessionPoolKeepAliveTimeout(keepAliveTimeout time.Duration) Option

func WithSessionPoolSizeLimit 

func WithSessionPoolSizeLimit(sizeLimit int) Option

func WithTLSSInsecureSkipVerify 

func WithTLSSInsecureSkipVerify() Option

func WithTableConfigOption 

func WithTableConfigOption(option tableConfig.Option) Option

func WithTraceCoordination 

func WithTraceCoordination(trace trace.Coordination) Option

WithTraceCoordination returns coordination trace option

func WithTraceDiscovery 

func WithTraceDiscovery(trace trace.Discovery) Option

WithTraceDiscovery returns discovery trace option

func WithTraceDriver 

func WithTraceDriver(trace trace.Driver) Option

WithTraceDriver returns deadline which has associated Driver with it.

func WithTraceRatelimiter 

func WithTraceRatelimiter(trace trace.Ratelimiter) Option

WithTraceRatelimiter returns ratelimiter trace option

func WithTraceScheme 

func WithTraceScheme(trace trace.Scheme) Option

WithTraceScheme returns scheme trace option

func WithTraceScripting 

func WithTraceScripting(trace trace.Scripting) Option

WithTraceScripting scripting trace option

func WithTraceTable 

func WithTraceTable(trace trace.Table) Option

WithTraceTable returns table trace option

func WithUserAgent 

func WithUserAgent(userAgent string) Option

Source Files

connection.go custom_options.go errors.go meta.go options.go proxy.go version.go

Directories

PathSynopsis
balancers
config
coordination
coordination/config
credentials
discovery
discovery/config
internal
log
ratelimiter
ratelimiter/config
retry
scheme
scheme/config
scripting
scripting/config
sugar
table
table/config
table/options
table/result
table/result/indexed
table/result/named
table/stats
table/types
test
testutil
testutil/timeutil
testutil/timeutil/timetest
trace
Version
v3.11.8-rc5
Published
Feb 26, 2022
Platform
darwin/amd64
Imports
40 packages
Last checked
now –

Tools for package owners.