rabbitmq_stream_protocol/
protocol.rs

1/// Low level stream commands
2///
3#[allow(unused)]
4pub mod commands {
5    pub const COMMAND_DECLARE_PUBLISHER: u16 = 1;
6    pub const COMMAND_PUBLISH: u16 = 2;
7    pub const COMMAND_PUBLISH_CONFIRM: u16 = 3;
8    pub const COMMAND_PUBLISH_ERROR: u16 = 4;
9    pub const COMMAND_QUERY_PUBLISHER_SEQUENCE: u16 = 5;
10    pub const COMMAND_DELETE_PUBLISHER: u16 = 6;
11    pub const COMMAND_SUBSCRIBE: u16 = 7;
12    pub const COMMAND_DELIVER: u16 = 8;
13    pub const COMMAND_CREDIT: u16 = 9;
14    pub const COMMAND_STORE_OFFSET: u16 = 10;
15    pub const COMMAND_QUERY_OFFSET: u16 = 11;
16    pub const COMMAND_UNSUBSCRIBE: u16 = 12;
17    pub const COMMAND_CREATE_STREAM: u16 = 13;
18    pub const COMMAND_DELETE_STREAM: u16 = 14;
19    pub const COMMAND_METADATA: u16 = 15;
20    pub const COMMAND_METADATA_UPDATE: u16 = 16;
21    pub const COMMAND_PEER_PROPERTIES: u16 = 17;
22    pub const COMMAND_SASL_HANDSHAKE: u16 = 18;
23    pub const COMMAND_SASL_AUTHENTICATE: u16 = 19;
24    pub const COMMAND_TUNE: u16 = 20;
25    pub const COMMAND_OPEN: u16 = 21;
26    pub const COMMAND_CLOSE: u16 = 22;
27    pub const COMMAND_HEARTBEAT: u16 = 23;
28    pub const COMMAND_ROUTE: u16 = 24;
29    pub const COMMAND_PARTITIONS: u16 = 25;
30    pub const COMMAND_CONSUMER_UPDATE: u16 = 26;
31    pub const COMMAND_EXCHANGE_COMMAND_VERSIONS: u16 = 27;
32    pub const COMMAND_STREAMS_STATS: u16 = 28;
33    pub const COMMAND_CREATE_SUPER_STREAM: u16 = 29;
34    pub const COMMAND_DELETE_SUPER_STREAM: u16 = 30;
35    pub const COMMAND_CONSUMER_UPDATE_REQUEST: u16 = 32794;
36}
37
38// server responses
39//
40#[allow(unused)]
41pub mod responses {
42    pub const RESPONSE_CODE_OK: u16 = 1;
43    pub const RESPONSE_CODE_STREAM_DOES_NOT_EXIST: u16 = 2;
44    pub const RESPONSE_CODE_SUBSCRIPTION_ID_ALREADY_EXISTS: u16 = 3;
45    pub const RESPONSE_CODE_SUBSCRIPTION_ID_DOES_NOT_EXIST: u16 = 4;
46    pub const RESPONSE_CODE_STREAM_ALREADY_EXISTS: u16 = 5;
47    pub const RESPONSE_CODE_STREAM_NOT_AVAILABLE: u16 = 6;
48    pub const RESPONSE_CODE_SASL_MECHANISM_NOT_SUPPORTED: u16 = 7;
49    pub const RESPONSE_CODE_AUTHENTICATION_FAILURE: u16 = 8;
50    pub const RESPONSE_CODE_SASL_ERROR: u16 = 9;
51    pub const RESPONSE_CODE_SASL_CHALLENGE: u16 = 10;
52    pub const RESPONSE_CODE_AUTHENTICATION_FAILURE_LOOPBACK: u16 = 11;
53    pub const RESPONSE_CODE_VIRTUAL_HOST_ACCESS_FAILURE: u16 = 12;
54    pub const RESPONSE_CODE_UNKNOWN_FRAME: u16 = 13;
55    pub const RESPONSE_CODE_FRAME_TOO_LARGE: u16 = 14;
56    pub const RESPONSE_CODE_INTERNAL_ERROR: u16 = 15;
57    pub const RESPONSE_CODE_ACCESS_REFUSED: u16 = 16;
58    pub const RESPONSE_CODE_PRECONDITION_FAILED: u16 = 17;
59    pub const RESPONSE_CODE_PUBLISHER_DOES_NOT_EXIST: u16 = 18;
60    pub const RESPONSE_CODE_OFFSET_NOT_FOUND: u16 = 19;
61}
62
63// protocol version between client and server
64
65#[allow(unused)]
66pub mod version {
67    pub const PROTOCOL_VERSION: u16 = 1;
68    pub const PROTOCOL_VERSION_2: u16 = 2;
69}
rabbitmq_stream_protocol/protocol.rs

rabbitmq_stream_protocol/
protocol.rs
