[−][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 |