[−][src]Crate pulsar
Re-exports
pub use message::proto; |
pub use message::proto::command_subscribe::SubType; |
Modules
| message |
Structs
| Ack | |
| Authentication | |
| Connection | |
| ConnectionManager | Look up broker addresses for topics and partitioned topics |
| Consumer | |
| ConsumerBuilder | |
| Producer | |
| Pulsar | |
| ServiceDiscovery | Look up broker addresses for topics and partitioned topics |
Enums
| ConnectionError | |
| ConsumerError | |
| Error | |
| ProducerError | |
| ServiceDiscoveryError |
Traits
| DeserializeMessage | Helper trait for consumer deserialization |