package proto
import "github.com/ClickHouse/clickhouse-go/v2/lib/proto"
Index ¶
- Constants
- func CheckMinVersion(constraint Version, version Version) bool
- type Block
- func (b *Block) AddColumn(name string, ct column.Type) error
- func (b *Block) Append(v ...any) (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) (err error)
- func (b *Block) EncodeColumn(buffer *proto.Buffer, revision uint64, i int) (err error)
- func (b *Block) EncodeHeader(buffer *proto.Buffer, revision uint64) (err error)
- func (b *Block) Reset()
- func (b *Block) Rows() int
- func (b *Block) SortColumns(columns []string) error
- type BlockError
- type ClientHandshake
- type Exception
- type Parameter
- type Parameters
- type ProfileInfo
- func (p *ProfileInfo) Decode(reader *chproto.Reader, revision uint64) (err error)
- func (p *ProfileInfo) String() string
- type Progress
- func (p *Progress) Decode(reader *chproto.Reader, revision uint64) (err error)
- func (p *Progress) String() string
- type Query
- type ServerHandshake
- func (srv *ServerHandshake) Decode(reader *chproto.Reader) (err error)
- func (srv ServerHandshake) String() string
- type Setting
- type Settings
- type TableColumns
- func (t *TableColumns) Decode(reader *chproto.Reader, revision uint64) (err error)
- func (t *TableColumns) String() string
- type Version
Constants ¶
const ( DBMS_MIN_REVISION_WITH_CLIENT_INFO = 54032 DBMS_MIN_REVISION_WITH_SERVER_TIMEZONE = 54058 DBMS_MIN_REVISION_WITH_QUOTA_KEY_IN_CLIENT_INFO = 54060 DBMS_MIN_REVISION_WITH_SERVER_DISPLAY_NAME = 54372 DBMS_MIN_REVISION_WITH_VERSION_PATCH = 54401 DBMS_MIN_REVISION_WITH_CLIENT_WRITE_INFO = 54420 DBMS_MIN_REVISION_WITH_SETTINGS_SERIALIZED_AS_STRINGS = 54429 DBMS_MIN_REVISION_WITH_INTERSERVER_SECRET = 54441 DBMS_MIN_REVISION_WITH_OPENTELEMETRY = 54442 DBMS_MIN_PROTOCOL_VERSION_WITH_DISTRIBUTED_DEPTH = 54448 DBMS_MIN_PROTOCOL_VERSION_WITH_INITIAL_QUERY_START_TIME = 54449 DBMS_MIN_PROTOCOL_VERSION_WITH_INCREMENTAL_PROFILE_EVENTS = 54451 DBMS_MIN_REVISION_WITH_PARALLEL_REPLICAS = 54453 DBMS_MIN_REVISION_WITH_CUSTOM_SERIALIZATION = 54454 DBMS_MIN_PROTOCOL_VERSION_WITH_ADDENDUM = 54458 DBMS_MIN_PROTOCOL_VERSION_WITH_QUOTA_KEY = 54458 DBMS_MIN_PROTOCOL_VERSION_WITH_PARAMETERS = 54459 DBMS_MIN_PROTOCOL_VERSION_WITH_SERVER_QUERY_TIME_IN_PROGRES = 54460 DBMS_TCP_PROTOCOL_VERSION = DBMS_MIN_PROTOCOL_VERSION_WITH_SERVER_QUERY_TIME_IN_PROGRES )
see https://github.com/ClickHouse/ClickHouse/blob/master/src/Core/Protocol.h
const ( ClientHello = 0 ClientQuery = 1 ClientData = 2 ClientCancel = 3 ClientPing = 4 )
const ( ClientQueryNone = 0 ClientQueryInitial = 1 ClientQuerySecondary = 2 )
const ( ServerHello = 0 ServerData = 1 ServerException = 2 ServerProgress = 3 ServerPong = 4 ServerEndOfStream = 5 ServerProfileInfo = 6 ServerTotals = 7 ServerExtremes = 8 ServerTablesStatus = 9 ServerLog = 10 ServerTableColumns = 11 ServerPartUUIDs = 12 ServerReadTaskRequest = 13 ServerProfileEvents = 14 ServerTreeReadTaskRequest = 15 )
const (
StateComplete = 2
)
Functions ¶
func CheckMinVersion ¶
Types ¶
type Block ¶
type Block struct { Packet byte Columns []column.Interface Timezone *time.Location // contains filtered or unexported fields }
func (*Block) AddColumn ¶
func (*Block) Append ¶
func (*Block) ColumnsNames ¶
func (*Block) Decode ¶
func (*Block) Encode ¶
func (*Block) EncodeColumn ¶
func (*Block) EncodeHeader ¶
func (*Block) Reset ¶
func (b *Block) Reset()
func (*Block) Rows ¶
func (*Block) SortColumns ¶
SortColumns sorts our block according to the requested order - a slice of column names. Names must be identical in requested order and block.
type BlockError ¶
func (*BlockError) Error ¶
func (e *BlockError) Error() string
type ClientHandshake ¶
func (ClientHandshake) Encode ¶
func (h ClientHandshake) Encode(buffer *chproto.Buffer)
func (ClientHandshake) String ¶
func (h ClientHandshake) String() string
type Exception ¶
type Exception struct { Code int32 Name string Message string StackTrace string Nested []Exception // contains filtered or unexported fields }
func (*Exception) Decode ¶
func (*Exception) Error ¶
type Parameter ¶
type Parameters ¶
type Parameters []Parameter
func (Parameters) Encode ¶
func (s Parameters) Encode(buffer *chproto.Buffer, revision uint64) error
type ProfileInfo ¶
type ProfileInfo struct { Rows uint64 Bytes uint64 Blocks uint64 AppliedLimit bool RowsBeforeLimit uint64 CalculatedRowsBeforeLimit bool }
func (*ProfileInfo) Decode ¶
func (p *ProfileInfo) Decode(reader *chproto.Reader, revision uint64) (err error)
func (*ProfileInfo) String ¶
func (p *ProfileInfo) String() string
type Progress ¶
type Progress struct { Rows uint64 Bytes uint64 TotalRows uint64 WroteRows uint64 WroteBytes uint64 Elapsed time.Duration // contains filtered or unexported fields }
func (*Progress) Decode ¶
func (*Progress) String ¶
type Query ¶
type Query struct { ID string ClientName string ClientVersion Version ClientTCPProtocolVersion uint64 Span trace.SpanContext Body string QuotaKey string Settings Settings Parameters Parameters Compression bool InitialUser string InitialAddress string }
func (*Query) Encode ¶
type ServerHandshake ¶
type ServerHandshake struct { Name string DisplayName string Revision uint64 Version Version Timezone *time.Location }
func (*ServerHandshake) Decode ¶
func (srv *ServerHandshake) Decode(reader *chproto.Reader) (err error)
func (ServerHandshake) String ¶
func (srv ServerHandshake) String() string
type Setting ¶
type Settings ¶
type Settings []Setting
func (Settings) Encode ¶
type TableColumns ¶
func (*TableColumns) Decode ¶
func (t *TableColumns) Decode(reader *chproto.Reader, revision uint64) (err error)
func (*TableColumns) String ¶
func (t *TableColumns) String() string
type Version ¶
func ParseVersion ¶
func (Version) String ¶
func (*Version) UnmarshalYAML ¶
Source Files ¶
block.go const.go exception.go handshake.go profile_info.go progress.go query.go table_columns.go
- Version
- v2.34.0 (latest)
- Published
- Apr 1, 2025
- Platform
- linux/amd64
- Imports
- 13 packages
- Last checked
- 4 minutes ago –
Tools for package owners.