pulsar-binary-protocol-spec 0.0.1

Pulsar binary protocol specification
Documentation 
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

#[macro_use]
mod macro_make_x_id_builder_and_x_id;

pub mod ack_type;
pub mod ack_validation_error;
pub mod compression_type;
pub mod message_id_data;
pub mod message_metadata;
pub mod message_properties;
pub mod producer_name;
pub mod protocol_version;
pub mod server_error;
pub mod single_message_metadata;
pub mod subscribe_type;

pub mod consumer_id;
pub mod producer_id;
pub mod request_id;
pub mod sequence_id;

pub use ack_type::AckType;
pub use ack_validation_error::AckValidationError;
pub use compression_type::CompressionType;
pub use message_id_data::MessageIdData;
pub use message_metadata::MessageMetadata;
pub use message_properties::MessageProperties;
pub use producer_name::ProducerName;
pub use protocol_version::ProtocolVersion;
pub use server_error::ServerError;
pub use single_message_metadata::SingleMessageMetadata;
pub use subscribe_type::SubscribeType;

pub use consumer_id::{ConsumerId, ConsumerIdBuilder};
pub use producer_id::{ProducerId, ProducerIdBuilder};
pub use request_id::{RequestId, RequestIdBuilder};
pub use sequence_id::{SequenceId, SequenceIdBuilder};