rocketmq-protocol-1.0.0
Platform
- x86_64-unknown-linux-gnu
Feature flags

docs.rs

Rust

rocketmq-protocol 1.0.0

Runtime-neutral RocketMQ wire protocol contracts

Crate
Source
Builds
Feature flags

..
broker
controller
message_operation_header
namesrv
ack_message_request_header.rs
add_broker_request_header.rs
broker.rs
change_invisible_time_request_header.rs
change_invisible_time_response_header.rs
check_rocksdb_cq_write_progress_request_header.rs
check_transaction_state_request_header.rs
check_transaction_state_response_header.rs
client_request_header.rs
clone_group_offset_request_header.rs
consume_message_directly_result_request_header.rs
consumer_send_msg_back_request_header.rs
controller.rs
create_acl_request_header.rs
create_topic_list_request_header.rs
create_topic_request_header.rs
create_user_request_header.rs
delete_acl_request_header.rs
delete_subscription_group_request_header.rs
delete_topic_request_header.rs
delete_user_request_header.rs
elect_master_response_header.rs
empty_header.rs
end_transaction_request_header.rs
exchange_ha_info_request_header.rs
exchange_ha_info_response_header.rs
export_rocksdb_config_to_json_request_header.rs
extra_info_util.rs
get_acl_request_header.rs
get_all_producer_info_request_header.rs
get_all_subscription_group_request_header.rs
get_all_topic_config_request_header.rs
get_all_topic_config_response_header.rs
get_broker_config_response_header.rs
get_consume_stats_in_broker_header.rs
get_consume_stats_request_header.rs
get_consumer_connection_list_request_header.rs
get_consumer_listby_group_request_header.rs
get_consumer_listby_group_response_header.rs
get_consumer_running_info_request_header.rs
get_consumer_status_request_header.rs
get_earliest_msg_storetime_request_header.rs
get_earliest_msg_storetime_response_header.rs
get_lite_client_info_request_header.rs
get_lite_group_info_request_header.rs
get_lite_topic_info_request_header.rs
get_max_offset_request_header.rs
get_max_offset_response_header.rs
get_meta_data_response_header.rs
get_min_offset_request_header.rs
get_min_offset_response_header.rs
get_parent_topic_info_request_header.rs
get_producer_connection_list_request_header.rs
get_subscription_group_config_request_header.rs
get_topic_config_request_header.rs
get_topic_stats_info_request_header.rs
get_topic_stats_request_header.rs
get_user_request_headers.rs
heartbeat_request_header.rs
list_acl_request_header.rs
list_users_request_header.rs
lite_subscription_ctl_request_header.rs
lock_batch_mq_request_header.rs
maintenance_request_header.rs
message_operation_header.rs
namesrv.rs
notification_request_header.rs
notification_response_header.rs
notify_broker_role_change_request_header.rs
notify_consumer_ids_changed_request_header.rs
notify_unsubscribe_lite_request_header.rs
peek_message_request_header.rs
polling_info_request_header.rs
polling_info_response_header.rs
pop_lite_message_request_header.rs
pop_lite_message_response_header.rs
pop_message_request_header.rs
pop_message_response_header.rs
pull_message_request_header.rs
pull_message_response_header.rs
query_consume_queue_request_header.rs
query_consume_time_span_request_header.rs
query_consumer_offset_request_header.rs
query_consumer_offset_response_header.rs
query_correction_offset_header.rs
query_message_request_header.rs
query_message_response_header.rs
query_subscription_by_consumer_request_header.rs
query_topic_consume_by_who_request_header.rs
query_topics_by_consumer_request_header.rs
recall_message_request_header.rs
recall_message_response_header.rs
remove_broker_request_header.rs
reply_message_request_header.rs
reset_master_flush_offset_header.rs
reset_offset_request_header.rs
resume_check_half_message_request_header.rs
search_offset_request_header.rs
search_offset_response_header.rs
trigger_lite_dispatch_request_header.rs
unlock_batch_mq_request_header.rs
unregister_client_request_header.rs
update_acl_request_header.rs
update_broker_config_request_header.rs
update_broker_config_response_header.rs
update_consumer_offset_conditional_header.rs
update_consumer_offset_header.rs
update_global_white_addrs_config_request_header.rs
update_group_forbidden_request_header.rs
update_subscription_group_config_cas_request_header.rs
update_subscription_group_config_cas_response_header.rs
update_topic_config_cas_request_header.rs
update_topic_config_cas_response_header.rs
update_user_request_header.rs
view_broker_stats_data_request_header.rs
view_message_request_header.rs
view_message_response_header.rs