1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35

// Name, version, revision, default DB
pub const CLIENT_HELLO: u64 = 0;
// Query id, query settings, stage up to which the query must be executed,
// whether the compression must be used,
// query text (without data for INSERTs).
// A block of data (compressed or not).
pub const CLIENT_QUERY: u64 = 1;
// A block of data (compressed or not).
pub const CLIENT_DATA: u64 = 2;
// Cancel the query execution.
pub const CLIENT_CANCEL: u64 = 3;
// Check that connection to the server is alive.
pub const CLIENT_PING: u64 = 4;
// Check status of tables on the server
pub const CLIENT_TABLES_STATUS_REQUEST: u64 = 5;
// Keep the connection alive
pub const CLIENT_KEEP_ALIVE: u64 = 6;
// A block of data (compressed or not)
pub const CLIENT_SCALAR: u64 = 7;
// List of unique parts ids to exclude from query processing
pub const CLIENT_INGORED_PART_UUIDS: u64 = 8;

pub const SERVER_HELLO: u64 = 0;
pub const SERVER_DATA: u64 = 1;
pub const SERVER_EXCEPTION: u64 = 2;
pub const SERVER_PROGRESS: u64 = 3;
pub const SERVER_PONG: u64 = 4;
pub const SERVER_END_OF_STREAM: u64 = 5;
pub const SERVER_PROFILE_INFO: u64 = 6;
pub const SERVER_TOTALS: u64 = 7;
pub const SERVER_EXTREMES: u64 = 8;

pub const NO_QUERY: u8 = 0;
pub const INITIAL_QUERY: u8 = 1;
pub const SECONDARY_QUERY: u8 = 2;