logging

Documentation

Index

• Variables
• func NewConnectionManager(cfg *config.TLoggingConfig, base rdbms_utils.ConnectionManagerBase, ...) rdbms_utils.ConnectionManager
• func NewSQLFormatter(mode config.TYdbConfig_Mode, cfg *config.TPushdownConfig) rdbms_utils.SQLFormatter
• func NewSplitProvider() rdbms_utils.SplitProvider
• type Resolver
  • func NewResolver(cfg *config.TLoggingConfig) (Resolver, error)
• type TSplitDescription
  • func (*TSplitDescription) Descriptor() ([]byte, []int)
  • func (x *TSplitDescription) GetShardIds() []uint64
  • func (*TSplitDescription) ProtoMessage()
  • func (x *TSplitDescription) ProtoReflect() protoreflect.Message
  • func (x *TSplitDescription) Reset()
  • func (x *TSplitDescription) String() string

Variables

var File_app_server_datasource_rdbms_logging_split_proto protoreflect.FileDescriptor

Functions

func NewConnectionManager

func NewConnectionManager(
	cfg *config.TLoggingConfig,
	base rdbms_utils.ConnectionManagerBase,
	resolver Resolver,
) rdbms_utils.ConnectionManager

func NewSQLFormatter

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

func NewSplitProvider

func NewSplitProvider() rdbms_utils.SplitProvider

Types

type Resolver

type Resolver interface {
	Close() error
	// contains filtered or unexported methods
}

func NewResolver

func NewResolver(cfg *config.TLoggingConfig) (Resolver, error)

type TSplitDescription

type TSplitDescription 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) Descriptor

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

Deprecated: Use TSplitDescription.ProtoReflect.Descriptor instead.

func (*TSplitDescription) GetShardIds

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

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