connector

Documentation

Index

• Constants
• Variables
• type Connector
  • func Open(parent ydbDriver, balancer grpc.ClientConnInterface, opts ...Option) (_ *Connector, err error)
  • func Unwrap[T *sql.DB | *sql.Conn](v T) (connector *Connector, _ error)
  • func (c *Connector) Bindings() bind.Bindings
  • func (c *Connector) Clock() clockwork.Clock
  • func (c *Connector) Close() error
  • func (c *Connector) Connect(ctx context.Context) (driver.Conn, error)
  • func (c *Connector) Driver() driver.Driver
  • func (c *Connector) Name() string
  • func (c *Connector) Open(name string) (driver.Conn, error)
  • func (c *Connector) Parent() ydbDriver
  • func (c *Connector) Query() *query.Client
  • func (c *Connector) RetryBudget() budget.Budget
  • func (c *Connector) Scheme() scheme.Client
  • func (c *Connector) Scripting() scripting.Client
  • func (c *Connector) Table() table.Client
  • func (c *Connector) Trace() *trace.DatabaseSQL
  • func (c *Connector) TraceRetry() *trace.Retry
• type Option
  • func OverQueryService() Option
  • func OverTableService() Option
  • func WithDefaultQueryMode(mode tableSql.QueryMode) Option
  • func WithDisableServerBalancer() Option
  • func WithFakeTx(modes ...tableSql.QueryMode) Option
  • func WithIdleThreshold(idleThreshold time.Duration) Option
  • func WithOnClose(onClose func(*Connector)) Option
  • func WithQueryOptions(opts ...querySql.Option) Option
  • func WithRetryBudget(budget budget.Budget) Option
  • func WithTableOptions(opts ...tableSql.Option) Option
  • func WithTrace(t *trace.DatabaseSQL, opts ...trace.DatabaseSQLComposeOption) Option
  • func WithTraceRetry(t *trace.Retry, opts ...trace.RetryComposeOption) Option
• type QueryBindOption
  • func WithQueryBind(bind bind.Bind) QueryBindOption
  • func WithTablePathPrefix(tablePathPrefix string) QueryBindOption

Constants

const (
	QUERY_SERVICE = iota + 1 //nolint:revive,stylecheck
	TABLE_SERVICE            //nolint:revive,stylecheck
)

Variables

var (
	ErrUnsupported = driver.ErrSkip
)

Types

type Connector

type Connector struct {
	TableOpts []tableSql.Option
	QueryOpts []querySql.Option
	// contains filtered or unexported fields
}

func Open

func Open(parent ydbDriver, balancer grpc.ClientConnInterface, opts ...Option) (_ *Connector, err error)

func Unwrap

func Unwrap[T *sql.DB | *sql.Conn](v T) (connector *Connector, _ error)

func (*Connector) Bindings

func (c *Connector) Bindings() bind.Bindings

func (*Connector) Clock

func (c *Connector) Clock() clockwork.Clock

func (*Connector) Close

func (c *Connector) Close() error

func (*Connector) Connect

func (c *Connector) Connect(ctx context.Context) (driver.Conn, error)

func (*Connector) Driver

func (c *Connector) Driver() driver.Driver

func (*Connector) Name

func (c *Connector) Name() string

func (*Connector) Open

func (c *Connector) Open(name string) (driver.Conn, error)

func (*Connector) Parent

func (c *Connector) Parent() ydbDriver

func (*Connector) Query

func (c *Connector) Query() *query.Client

func (*Connector) RetryBudget

func (c *Connector) RetryBudget() budget.Budget

func (*Connector) Scheme

func (c *Connector) Scheme() scheme.Client

func (*Connector) Scripting

func (c *Connector) Scripting() scripting.Client

func (*Connector) Table

func (c *Connector) Table() table.Client

func (*Connector) Trace

func (c *Connector) Trace() *trace.DatabaseSQL

func (*Connector) TraceRetry

func (c *Connector) TraceRetry() *trace.Retry

type Option

type Option interface {
	Apply(c *Connector) error
}

func OverQueryService

func OverQueryService() Option

func OverTableService

func OverTableService() Option

func WithDefaultQueryMode

func WithDefaultQueryMode(mode tableSql.QueryMode) Option

func WithDisableServerBalancer

func WithDisableServerBalancer() Option

func WithFakeTx

func WithFakeTx(modes ...tableSql.QueryMode) Option

func WithIdleThreshold

func WithIdleThreshold(idleThreshold time.Duration) Option

func WithOnClose

func WithOnClose(onClose func(*Connector)) Option

func WithQueryOptions

func WithQueryOptions(opts ...querySql.Option) Option

func WithRetryBudget

func WithRetryBudget(budget budget.Budget) Option

func WithTableOptions

func WithTableOptions(opts ...tableSql.Option) Option

func WithTrace

func WithTrace(
	t *trace.DatabaseSQL,
	opts ...trace.DatabaseSQLComposeOption,
) Option

func WithTraceRetry

func WithTraceRetry(
	t *trace.Retry,
	opts ...trace.RetryComposeOption,
) Option

type QueryBindOption

type QueryBindOption interface {
	Option
	bind.Bind
}

func WithQueryBind

func WithQueryBind(bind bind.Bind) QueryBindOption

func WithTablePathPrefix

func WithTablePathPrefix(tablePathPrefix string) QueryBindOption