ydb

Documentation

Overview

Package ydb contains code specific for YDB database.

Index

• Variables
• func ErrorCheckerQuery(err error) bool
• func NewConnectionManager(cfg *config.TYdbConfig, base rdbms_utils.ConnectionManagerBase) rdbms_utils.ConnectionManager
• func NewSQLFormatter(mode config.TYdbConfig_Mode, cfg *config.TPushdownConfig) rdbms_utils.SQLFormatter
• func NewSchemaProvider(typeMapper datasource.TypeMapper) rdbms_utils.SchemaProvider
• func NewSplitProvider(cfg *config.TYdbConfig_TSplitting) rdbms_utils.SplitProvider
• func NewTypeMapper() datasource.TypeMapper
• type Connection
• type TSplitDescription
  • func (*TSplitDescription) Descriptor() ([]byte, []int)
  • func (x *TSplitDescription) GetColumnShard() *TSplitDescription_ColumnShard
  • func (x *TSplitDescription) GetDataShard() *TSplitDescription_DataShard
  • func (x *TSplitDescription) GetShard() isTSplitDescription_Shard
  • func (*TSplitDescription) ProtoMessage()
  • func (x *TSplitDescription) ProtoReflect() protoreflect.Message
  • func (x *TSplitDescription) Reset()
  • func (x *TSplitDescription) String() string
• type TSplitDescription_ColumnShard
  • func (*TSplitDescription_ColumnShard) Descriptor() ([]byte, []int)
  • func (x *TSplitDescription_ColumnShard) GetShardIds() []uint64
  • func (*TSplitDescription_ColumnShard) ProtoMessage()
  • func (x *TSplitDescription_ColumnShard) ProtoReflect() protoreflect.Message
  • func (x *TSplitDescription_ColumnShard) Reset()
  • func (x *TSplitDescription_ColumnShard) String() string
• type TSplitDescription_ColumnShard_
• type TSplitDescription_DataShard
  • func (*TSplitDescription_DataShard) Descriptor() ([]byte, []int)
  • func (*TSplitDescription_DataShard) ProtoMessage()
  • func (x *TSplitDescription_DataShard) ProtoReflect() protoreflect.Message
  • func (x *TSplitDescription_DataShard) Reset()
  • func (x *TSplitDescription_DataShard) String() string
• type TSplitDescription_DataShard_

Variables

var File_app_server_datasource_rdbms_ydb_split_proto protoreflect.FileDescriptor

Functions

func ErrorCheckerQuery

func ErrorCheckerQuery(err error) bool

func NewConnectionManager

func NewConnectionManager(
	cfg *config.TYdbConfig,
	base rdbms_utils.ConnectionManagerBase,
) rdbms_utils.ConnectionManager

func NewSQLFormatter

func NewSQLFormatter(mode config.TYdbConfig_Mode, cfg *config.TPushdownConfig) rdbms_utils.SQLFormatter

func NewSchemaProvider

func NewSchemaProvider(
	typeMapper datasource.TypeMapper,
) rdbms_utils.SchemaProvider

func NewSplitProvider

func NewSplitProvider(cfg *config.TYdbConfig_TSplitting) rdbms_utils.SplitProvider

func NewTypeMapper

func NewTypeMapper() datasource.TypeMapper

Types

type Connection

type Connection interface {
	rdbms_utils.Connection
	Driver() *ydb_sdk.Driver
}

type TSplitDescription

type TSplitDescription struct {

	// Types that are valid to be assigned to Shard:
	//
	//	*TSplitDescription_DataShard_
	//	*TSplitDescription_ColumnShard_
	Shard isTSplitDescription_Shard `protobuf_oneof:"shard"`
	// contains filtered or unexported fields
}

func (*TSplitDescription) Descriptor

func (*TSplitDescription) Descriptor() ([]byte, []int)

Deprecated: Use TSplitDescription.ProtoReflect.Descriptor instead.

func (*TSplitDescription) GetColumnShard

func (x *TSplitDescription) GetColumnShard() *TSplitDescription_ColumnShard

func (*TSplitDescription) GetDataShard

func (x *TSplitDescription) GetDataShard() *TSplitDescription_DataShard

func (*TSplitDescription) GetShard

func (x *TSplitDescription) GetShard() isTSplitDescription_Shard

func (*TSplitDescription) ProtoMessage

func (*TSplitDescription) ProtoMessage()

func (*TSplitDescription) ProtoReflect

func (x *TSplitDescription) ProtoReflect() protoreflect.Message

func (*TSplitDescription) Reset

func (x *TSplitDescription) Reset()

func (*TSplitDescription) String

func (x *TSplitDescription) String() string

type TSplitDescription_ColumnShard

type TSplitDescription_ColumnShard struct {
	ShardIds []uint64 `protobuf:"varint,1,rep,packed,name=shard_ids,json=shardIds,proto3" json:"shard_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TSplitDescription_ColumnShard) Descriptor

func (*TSplitDescription_ColumnShard) Descriptor() ([]byte, []int)

Deprecated: Use TSplitDescription_ColumnShard.ProtoReflect.Descriptor instead.

func (*TSplitDescription_ColumnShard) GetShardIds

func (x *TSplitDescription_ColumnShard) GetShardIds() []uint64

func (*TSplitDescription_ColumnShard) ProtoMessage

func (*TSplitDescription_ColumnShard) ProtoMessage()

func (*TSplitDescription_ColumnShard) ProtoReflect

func (x *TSplitDescription_ColumnShard) ProtoReflect() protoreflect.Message

func (*TSplitDescription_ColumnShard) Reset

func (x *TSplitDescription_ColumnShard) Reset()

func (*TSplitDescription_ColumnShard) String

func (x *TSplitDescription_ColumnShard) String() string

type TSplitDescription_ColumnShard_

type TSplitDescription_ColumnShard_ struct {
	ColumnShard *TSplitDescription_ColumnShard `protobuf:"bytes,2,opt,name=column_shard,json=columnShard,proto3,oneof"`
}

type TSplitDescription_DataShard

type TSplitDescription_DataShard struct {
	// contains filtered or unexported fields
}

func (*TSplitDescription_DataShard) Descriptor

func (*TSplitDescription_DataShard) Descriptor() ([]byte, []int)

Deprecated: Use TSplitDescription_DataShard.ProtoReflect.Descriptor instead.

func (*TSplitDescription_DataShard) ProtoMessage

func (*TSplitDescription_DataShard) ProtoMessage()

func (*TSplitDescription_DataShard) ProtoReflect

func (x *TSplitDescription_DataShard) ProtoReflect() protoreflect.Message

func (*TSplitDescription_DataShard) Reset

func (x *TSplitDescription_DataShard) Reset()

func (*TSplitDescription_DataShard) String

func (x *TSplitDescription_DataShard) String() string

type TSplitDescription_DataShard_

type TSplitDescription_DataShard_ struct {
	DataShard *TSplitDescription_DataShard `protobuf:"bytes,1,opt,name=data_shard,json=dataShard,proto3,oneof"`
}