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
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60

/// Low level stream commands
///
#[allow(unused)]
pub mod commands {
    pub const COMMAND_DECLARE_PUBLISHER: u16 = 1;
    pub const COMMAND_PUBLISH: u16 = 2;
    pub const COMMAND_PUBLISH_CONFIRM: u16 = 3;
    pub const COMMAND_PUBLISH_ERROR: u16 = 4;
    pub const COMMAND_QUERY_PUBLISHER_SEQUENCE: u16 = 5;
    pub const COMMAND_DELETE_PUBLISHER: u16 = 6;
    pub const COMMAND_SUBSCRIBE: u16 = 7;
    pub const COMMAND_DELIVER: u16 = 8;
    pub const COMMAND_CREDIT: u16 = 9;
    pub const COMMAND_STORE_OFFSET: u16 = 10;
    pub const COMMAND_QUERY_OFFSET: u16 = 11;
    pub const COMMAND_UNSUBSCRIBE: u16 = 12;
    pub const COMMAND_CREATE_STREAM: u16 = 13;
    pub const COMMAND_DELETE_STREAM: u16 = 14;
    pub const COMMAND_METADATA: u16 = 15;
    pub const COMMAND_METADATA_UPDATE: u16 = 16;
    pub const COMMAND_PEER_PROPERTIES: u16 = 17;
    pub const COMMAND_SASL_HANDSHAKE: u16 = 18;
    pub const COMMAND_SASL_AUTHENTICATE: u16 = 19;
    pub const COMMAND_TUNE: u16 = 20;
    pub const COMMAND_OPEN: u16 = 21;
    pub const COMMAND_CLOSE: u16 = 22;
    pub const COMMAND_HEARTBEAT: u16 = 23;
}

// server responses
//
#[allow(unused)]
pub mod responses {
    pub const RESPONSE_CODE_OK: u16 = 1;
    pub const RESPONSE_CODE_STREAM_DOES_NOT_EXIST: u16 = 2;
    pub const RESPONSE_CODE_SUBSCRIPTION_ID_ALREADY_EXISTS: u16 = 3;
    pub const RESPONSE_CODE_SUBSCRIPTION_ID_DOES_NOT_EXIST: u16 = 4;
    pub const RESPONSE_CODE_STREAM_ALREADY_EXISTS: u16 = 5;
    pub const RESPONSE_CODE_STREAM_NOT_AVAILABLE: u16 = 6;
    pub const RESPONSE_CODE_SASL_MECHANISM_NOT_SUPPORTED: u16 = 7;
    pub const RESPONSE_CODE_AUTHENTICATION_FAILURE: u16 = 8;
    pub const RESPONSE_CODE_SASL_ERROR: u16 = 9;
    pub const RESPONSE_CODE_SASL_CHALLENGE: u16 = 10;
    pub const RESPONSE_CODE_AUTHENTICATION_FAILURE_LOOPBACK: u16 = 11;
    pub const RESPONSE_CODE_VIRTUAL_HOST_ACCESS_FAILURE: u16 = 12;
    pub const RESPONSE_CODE_UNKNOWN_FRAME: u16 = 13;
    pub const RESPONSE_CODE_FRAME_TOO_LARGE: u16 = 14;
    pub const RESPONSE_CODE_INTERNAL_ERROR: u16 = 15;
    pub const RESPONSE_CODE_ACCESS_REFUSED: u16 = 16;
    pub const RESPONSE_CODE_PRECONDITION_FAILED: u16 = 17;
    pub const RESPONSE_CODE_PUBLISHER_DOES_NOT_EXIST: u16 = 18;
    pub const RESPONSE_CODE_OFFSET_NOT_FOUND: u16 = 19;
}

// protocol version between client and server

#[allow(unused)]
pub mod version {
    pub const PROTOCOL_VERSION: u16 = 1;
}