Files
zeekay 765c3d0aa1 hanzo-ds/native: de-branded native protocol lib (fork of clickhouse ch-go v0.71.0)
Module path, package names, and identifiers de-branded to native/proto/compress/
pool/tracing. Server wire-protocol strings preserved. Vendored codec surface used
by hanzo-ds/go (proto + compress).
2026-07-10 13:10:07 -07:00

40 lines
1.7 KiB
Go

package proto
//go:generate go run github.com/dmarkham/enumer -type ServerCode -trimprefix ServerCode -output server_code_enum.go
// ServerCode is sent by server to client.
type ServerCode byte
// Possible server codes.
const (
ServerCodeHello ServerCode = 0 // Server part of "handshake"
ServerCodeData ServerCode = 1 // data block (can be compressed)
ServerCodeException ServerCode = 2 // runtime exception
ServerCodeProgress ServerCode = 3 // query execution progress (bytes, lines)
ServerCodePong ServerCode = 4 // ping response (ClientPing)
ServerCodeEndOfStream ServerCode = 5 // all packets were transmitted
ServerCodeProfile ServerCode = 6 // profiling info
ServerCodeTotals ServerCode = 7 // packet with total values (can be compressed)
ServerCodeExtremes ServerCode = 8 // packet with minimums and maximums (can be compressed)
ServerCodeTablesStatus ServerCode = 9 // response to TablesStatus
ServerCodeLog ServerCode = 10 // query execution system log
ServerCodeTableColumns ServerCode = 11 // columns description
ServerPartUUIDs ServerCode = 12 // list of unique parts ids.
ServerReadTaskRequest ServerCode = 13 // String (UUID) describes a request for which next task is needed
ServerProfileEvents ServerCode = 14 // Packet with profile events from server
ServerCodeSSHChallenge ServerCode = 18 // return challenge for SSH signature signing
)
// Encode to buffer.
func (c ServerCode) Encode(b *Buffer) { b.PutByte(byte(c)) }
// Compressible reports whether message can be compressed.
func (c ServerCode) Compressible() bool {
switch c {
case ServerCodeData, ServerCodeTotals, ServerCodeExtremes:
return true
default:
return false
}
}