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