pulsar-binary-protocol-spec-0.0.1
- pulsar-binary-protocol-spec 0.0.1
- Permalink
- Docs.rs crate page
- Apache-2.0 OR MIT
- Links
- Homepage
- Repository
- crates.io
- Source
- Owners
- vkill
- Dependencies
- async-channel ^1.5 normal optional
  
  chrono ^0.4 normal
  
  crc32c ^0.6 normal
  
  flate2 ^1.0 normal optional
  
  futures-channel ^0.3 normal optional
  
  lz4 ^1.23 normal optional
  
  paste ^1.0 normal
  
  protobuf ^2.22 normal
  
  seq-macro ^0.2 normal
  
  thiserror ^1.0 normal
  
  test-case ^1.1 dev
  
  protoc-rust ^2.22 build
- Versions
- 0.42% of the crate is documented
Platform
Feature flags

docs.rs
- About docs.rs
- Privacy policy

Rust

Files

pulsar_binary_protocol_spec

client_channel

handler_channel_storage.rs mod.rs

client_channel_messages

consumer_send_handler_channel_message.rs handler_reply_consumer_channel_message.rs handler_reply_producer_channel_message.rs handler_reply_session_channel_message.rs mod.rs producer_send_handler_channel_message.rs session_send_handler_channel_message.rs

client_half_requests

consumer_flow_half_request.rs consumer_redeliver_unacknowledged_messages_half_request.rs macro_make_x_half_request_error.rs mod.rs

client_handler

errors.rs handle_ack_response.rs handle_connected.rs handle_error.rs handle_message.rs handle_ping.rs handle_pong.rs handle_producer_success.rs handle_send_error.rs handle_send_receipt.rs handle_success.rs mod.rs on_responded.rs pending_messages.rs pending_requests.rs pending_sequences.rs

client_responds

connect_respond.rs consumer_ack_respond.rs macro_make_x_respond_error.rs mod.rs producer_send_respond.rs session_create_consumer_respond.rs session_create_producer_respond.rs

commands

ack_command.rs ack_response_command.rs connect_command.rs connected_command.rs error_command.rs flow_command.rs message_command.rs mod.rs ping_command.rs pong_command.rs producer_command.rs producer_success_command.rs redeliver_unacknowledged_messages.rs send_command.rs send_error_command.rs send_receipt_command.rs subscribe_command.rs success_command.rs

compression

frame

mod.rs parser.rs renderer.rs

protos

protobuf

PulsarApi.rs mod.rs

mod.rs utils.rs

types

ack_type.rs ack_validation_error.rs compression_type.rs consumer_id.rs macro_make_x_id_builder_and_x_id.rs message_id_data.rs message_metadata.rs message_properties.rs mod.rs producer_id.rs producer_name.rs protocol_version.rs request_id.rs sequence_id.rs server_error.rs single_message_metadata.rs subscribe_type.rs

command.rs lib.rs

pulsar_binary_protocol_spec/protos/protobuf/
mod.rs

Settings

Help

1
2

pub mod PulsarApi;
pub use self::PulsarApi as pulsar_api;