Expand description
low level structures used to send and process raw messages
Re-exports§
pub use self::proto::BaseCommand;
pub use self::proto::MessageMetadata as Metadata;
Modules§
Structs§
- tokio and async-std codec for Pulsar messages
- Pulsar binary message
- message payload