Versions in this module Expand all Collapse all v2 v2.3.2 Nov 4, 2022 Changes in this version + const ClientCancel + const ClientData + const ClientHello + const ClientName + const ClientPing + const ClientQuery + const ClientQueryInitial + const ClientQueryNone + const ClientQuerySecondary + const ClientTCPProtocolVersion + const ClientVersionMajor + const ClientVersionMinor + const CompressDisable + const CompressEnable + const DBMS_MIN_PROTOCOL_VERSION_WITH_DISTRIBUTED_DEPTH + const DBMS_MIN_PROTOCOL_VERSION_WITH_INCREMENTAL_PROFILE_EVENTS + const DBMS_MIN_PROTOCOL_VERSION_WITH_INITIAL_QUERY_START_TIME + const DBMS_MIN_REVISION_WITH_CLIENT_INFO + const DBMS_MIN_REVISION_WITH_CLIENT_WRITE_INFO + const DBMS_MIN_REVISION_WITH_INTERSERVER_SECRET + const DBMS_MIN_REVISION_WITH_OPENTELEMETRY + const DBMS_MIN_REVISION_WITH_PARALLEL_REPLICAS + const DBMS_MIN_REVISION_WITH_QUOTA_KEY_IN_CLIENT_INFO + const DBMS_MIN_REVISION_WITH_SERVER_DISPLAY_NAME + const DBMS_MIN_REVISION_WITH_SERVER_TIMEZONE + const DBMS_MIN_REVISION_WITH_SETTINGS_SERIALIZED_AS_STRINGS + const DBMS_MIN_REVISION_WITH_VERSION_PATCH + const DBMS_TCP_PROTOCOL_VERSION + const ServerData + const ServerEndOfStream + const ServerException + const ServerExtremes + const ServerHello + const ServerLog + const ServerPartUUIDs + const ServerPong + const ServerProfileEvents + const ServerProfileInfo + const ServerProgress + const ServerReadTaskRequest + const ServerTableColumns + const ServerTablesStatus + const ServerTotals + const ServerTreeReadTaskRequest + const StateComplete + func CheckMinVersion(constraint Version, version Version) bool + type Block struct + Columns []column.Interface + Packet byte + Timezone *time.Location + func (b *Block) AddColumn(name string, ct column.Type) error + func (b *Block) Append(v ...interface{}) (err error) + func (b *Block) ColumnsNames() []string + func (b *Block) Decode(reader *proto.Reader, revision uint64) (err error) + func (b *Block) Encode(buffer *proto.Buffer, revision uint64) error + func (b *Block) Reset() + func (b *Block) Rows() int + func (b *Block) SortColumns(columns []string) error + type BlockError struct + ColumnName string + Err error + Op string + func (e *BlockError) Error() string + type ClientHandshake struct + func (ClientHandshake) Encode(buffer *chproto.Buffer) + func (ClientHandshake) String() string + type Exception struct + Code int32 + Message string + Name string + Nested []Exception + StackTrace string + func (e *Exception) Decode(reader *proto.Reader) (err error) + func (e *Exception) Error() string + type ProfileInfo struct + AppliedLimit bool + Blocks uint64 + Bytes uint64 + CalculatedRowsBeforeLimit bool + Rows uint64 + RowsBeforeLimit uint64 + func (p *ProfileInfo) Decode(reader *chproto.Reader, revision uint64) (err error) + func (p *ProfileInfo) String() string + type Progress struct + Bytes uint64 + Rows uint64 + TotalRows uint64 + WroteBytes uint64 + WroteRows uint64 + func (p *Progress) Decode(reader *chproto.Reader, revision uint64) (err error) + func (p *Progress) String() string + type Query struct + Body string + Compression bool + ID string + InitialAddress string + InitialUser string + QuotaKey string + Settings Settings + Span trace.SpanContext + func (q *Query) Encode(buffer *chproto.Buffer, revision uint64) error + type ServerHandshake struct + DisplayName string + Name string + Revision uint64 + Timezone *time.Location + Version Version + func (srv *ServerHandshake) Decode(reader *chproto.Reader) (err error) + func (srv ServerHandshake) String() string + type Setting struct + Key string + Value interface{} + type Settings []Setting + func (s Settings) Encode(buffer *chproto.Buffer, revision uint64) error + type TableColumns struct + First string + Second string + func (t *TableColumns) Decode(reader *chproto.Reader, revision uint64) (err error) + func (t *TableColumns) String() string + type Version struct + Major uint64 + Minor uint64 + Patch uint64 + func ParseVersion(v string) (ver Version, err error) + func (v *Version) UnmarshalYAML(value *yaml.Node) (err error) + func (v Version) String() string
Go to main page