config

Documentation

Index

• Variables
• type Config
  • func New(opts ...Option) Config
  • func (c Config) Balancer() balancer.Balancer
  • func (c Config) ConnectionTTL() time.Duration
  • func (c Config) Credentials() credentials.Credentials
  • func (c Config) Database() string
  • func (c Config) DialTimeout() time.Duration
  • func (c Config) Endpoint() string
  • func (c Config) ExcludeGRPCCodesForPessimization() []grpcCodes.Code
  • func (c Config) GrpcDialOptions() []grpc.DialOption
  • func (c Config) Meta() meta.Meta
  • func (c Config) RequestsType() string
  • func (c Config) Secure() bool
  • func (c Config) TLSConfig() *tls.Config
  • func (c Config) Trace() trace.Driver
  • func (c Config) UseDNSResolver() bool
• type Option
  • func ExcludeGRPCCodesForPessimization(codes ...grpcCodes.Code) Option
  • func WithBalancer(balancer balancer.Balancer) Option
  • func WithCertificate(certificate *x509.Certificate) Option
  • func WithConnectionTTL(ttl time.Duration) Option
  • func WithCredentials(credentials credentials.Credentials) Option
  • func WithDatabase(database string) Option
  • func WithDialTimeout(timeout time.Duration) Option
  • func WithEndpoint(endpoint string) Option
  • func WithGrpcOptions(option ...grpc.DialOption) Option
  • func WithInternalDNSResolver() Option
  • func WithMinTLSVersion(minVersion uint16) Option
  • func WithOperationCancelAfter(operationCancelAfter time.Duration) Option
  • func WithOperationTimeout(operationTimeout time.Duration) Option
  • func WithPanicCallback(panicCallback func(e interface{})) Option
  • func WithRequestsType(requestsType string) Option
  • func WithSecure(secure bool) Option
  • func WithTLSSInsecureSkipVerify() Option
  • func WithTrace(t trace.Driver, opts ...trace.DriverComposeOption) Option
  • func WithUserAgent(userAgent string) Option

Variables

var (
	// DefaultKeepaliveInterval contains default duration between grpc keepalive
	DefaultKeepaliveInterval    = 10 * time.Second
	MinKeepaliveInterval        = 10 * time.Second
	DefaultGRPCMsgSize          = 64 * 1024 * 1024 // 64MB
	DefaultGrpcConnectionPolicy = keepalive.ClientParameters{
		Time:                DefaultKeepaliveInterval,
		Timeout:             MinKeepaliveInterval,
		PermitWithoutStream: true,
	}
)

Types

type Config

type Config struct {
	config.Common
	// contains filtered or unexported fields
}

Config contains driver configuration.

func New

func New(opts ...Option) Config

func (Config) Balancer

func (c Config) Balancer() balancer.Balancer

Balancer is an optional configuration related to selected balancer. That is, some balancing methods allow to be configured.

func (Config) ConnectionTTL

func (c Config) ConnectionTTL() time.Duration

ConnectionTTL is a time to live of a connection If ConnectionTTL is zero then TTL is not used.

func (Config) Credentials

func (c Config) Credentials() credentials.Credentials

Credentials is an ydb client credentials. In most cases Credentials are required.

func (Config) Database

func (c Config) Database() string

Database is a required database name.

func (Config) DialTimeout

func (c Config) DialTimeout() time.Duration

DialTimeout is the maximum amount of time a dial will wait for a connect to complete.

If DialTimeout is zero then no timeout is used.

func (Config) Endpoint

func (c Config) Endpoint() string

Endpoint is a required starting endpoint for connect

func (Config) ExcludeGRPCCodesForPessimization

func (c Config) ExcludeGRPCCodesForPessimization() []grpcCodes.Code

ExcludeGRPCCodesForPessimization defines grpc codes for exclude its from pessimization trigger

func (Config) GrpcDialOptions

func (c Config) GrpcDialOptions() []grpc.DialOption

GrpcDialOptions is an custom client grpc dial options which will appends to default grpc dial options

func (Config) Meta

func (c Config) Meta() meta.Meta

Meta is an internal option which contains meta information about database connection

func (Config) RequestsType

func (c Config) RequestsType() string

RequestsType set an additional type hint to all requests. It is needed only for debug purposes and advanced cases.

func (Config) Secure

func (c Config) Secure() bool

Secure is an flag for secure connection

func (Config) TLSConfig

func (c Config) TLSConfig() *tls.Config

func (Config) Trace

func (c Config) Trace() trace.Driver

Trace contains driver tracing options.

func (Config) UseDNSResolver

func (c Config) UseDNSResolver() bool

UseDNSResolver is a flag about using dns-resolving or not

type Option

type Option func(c *Config)

func ExcludeGRPCCodesForPessimization

func ExcludeGRPCCodesForPessimization(codes ...grpcCodes.Code) Option

func WithBalancer

func WithBalancer(balancer balancer.Balancer) Option

func WithCertificate

func WithCertificate(certificate *x509.Certificate) Option

func WithConnectionTTL

func WithConnectionTTL(ttl time.Duration) Option

func WithCredentials

func WithCredentials(credentials credentials.Credentials) Option

func WithDatabase

func WithDatabase(database string) Option

func WithDialTimeout

func WithDialTimeout(timeout time.Duration) Option

func WithEndpoint

func WithEndpoint(endpoint string) Option

func WithGrpcOptions

func WithGrpcOptions(option ...grpc.DialOption) Option

func WithInternalDNSResolver

func WithInternalDNSResolver() Option

WithInternalDNSResolver disable dns-resolving before dialing If dns-resolving are disabled - dial used FQDN as address If dns-resolving are enabled - dial used IP-address

func WithMinTLSVersion

func WithMinTLSVersion(minVersion uint16) Option

func WithOperationCancelAfter

func WithOperationCancelAfter(operationCancelAfter time.Duration) Option

WithOperationCancelAfter sets the maximum amount of time a YDB server will process an operation. After timeout exceeds YDB will try to cancel operation and if it succeeds appropriate error will be returned to the client; otherwise processing will be continued.

If OperationCancelAfter is zero then no timeout is used.

func WithOperationTimeout

func WithOperationTimeout(operationTimeout time.Duration) Option

WithOperationTimeout defines the maximum amount of time a YDB server will process an operation. After timeout exceeds YDB will try to cancel operation and regardless of the cancellation appropriate error will be returned to the client.

If OperationTimeout is zero then no timeout is used.

func WithPanicCallback

func WithPanicCallback(panicCallback func(e interface{})) Option

WithPanicCallback applies panic callback to config

func WithRequestsType

func WithRequestsType(requestsType string) Option

func WithSecure

func WithSecure(secure bool) Option

func WithTLSSInsecureSkipVerify

func WithTLSSInsecureSkipVerify() Option

func WithTrace

func WithTrace(t trace.Driver, opts ...trace.DriverComposeOption) Option

func WithUserAgent

func WithUserAgent(userAgent string) Option