rocketmq_protocol/protocol/
header.rs

1// Copyright 2023 The RocketMQ Rust Authors
2//
3// Licensed under the Apache License, Version 2.0 (the "License");
4// you may not use this file except in compliance with the License.
5// You may obtain a copy of the License at
6//
7//     http://www.apache.org/licenses/LICENSE-2.0
8//
9// Unless required by applicable law or agreed to in writing, software
10// distributed under the License is distributed on an "AS IS" BASIS,
11// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12// See the License for the specific language governing permissions and
13// limitations under the License.
14
15pub mod ack_message_request_header;
16pub mod add_broker_request_header;
17pub mod broker;
18pub mod change_invisible_time_request_header;
19pub mod change_invisible_time_response_header;
20pub mod check_rocksdb_cq_write_progress_request_header;
21pub mod check_transaction_state_request_header;
22pub mod check_transaction_state_response_header;
23pub mod client_request_header;
24pub mod clone_group_offset_request_header;
25pub mod consume_message_directly_result_request_header;
26pub mod consumer_send_msg_back_request_header;
27pub mod controller;
28pub mod create_acl_request_header;
29pub mod create_topic_list_request_header;
30pub mod create_topic_request_header;
31pub mod create_user_request_header;
32pub mod delete_acl_request_header;
33pub mod delete_subscription_group_request_header;
34pub mod delete_topic_request_header;
35pub mod delete_user_request_header;
36pub mod elect_master_response_header;
37pub mod empty_header;
38pub mod end_transaction_request_header;
39pub mod exchange_ha_info_request_header;
40pub mod exchange_ha_info_response_header;
41pub mod export_rocksdb_config_to_json_request_header;
42pub mod extra_info_util;
43pub mod get_acl_request_header;
44pub mod get_all_producer_info_request_header;
45pub mod get_all_subscription_group_request_header;
46pub mod get_all_topic_config_request_header;
47pub mod get_all_topic_config_response_header;
48pub mod get_broker_config_response_header;
49pub mod get_consume_stats_in_broker_header;
50pub mod get_consume_stats_request_header;
51pub mod get_consumer_connection_list_request_header;
52pub mod get_consumer_listby_group_request_header;
53pub mod get_consumer_listby_group_response_header;
54pub mod get_consumer_running_info_request_header;
55pub mod get_consumer_status_request_header;
56pub mod get_earliest_msg_storetime_request_header;
57pub mod get_earliest_msg_storetime_response_header;
58pub mod get_lite_client_info_request_header;
59pub mod get_lite_group_info_request_header;
60pub mod get_lite_topic_info_request_header;
61pub mod get_max_offset_request_header;
62pub mod get_max_offset_response_header;
63pub mod get_meta_data_response_header;
64pub mod get_min_offset_request_header;
65pub mod get_min_offset_response_header;
66pub mod get_parent_topic_info_request_header;
67pub mod get_producer_connection_list_request_header;
68pub mod get_subscription_group_config_request_header;
69pub mod get_topic_config_request_header;
70pub mod get_topic_stats_info_request_header;
71pub mod get_topic_stats_request_header;
72pub mod get_user_request_headers;
73pub mod heartbeat_request_header;
74pub mod list_acl_request_header;
75pub mod list_users_request_header;
76pub mod lite_subscription_ctl_request_header;
77pub mod lock_batch_mq_request_header;
78pub mod maintenance_request_header;
79pub mod message_operation_header;
80pub mod namesrv;
81pub mod notification_request_header;
82pub mod notification_response_header;
83pub mod notify_broker_role_change_request_header;
84pub mod notify_consumer_ids_changed_request_header;
85pub mod notify_unsubscribe_lite_request_header;
86pub mod peek_message_request_header;
87pub mod polling_info_request_header;
88pub mod polling_info_response_header;
89pub mod pop_lite_message_request_header;
90pub mod pop_lite_message_response_header;
91pub mod pop_message_request_header;
92pub mod pop_message_response_header;
93pub mod pull_message_request_header;
94pub mod pull_message_response_header;
95pub mod query_consume_queue_request_header;
96pub mod query_consume_time_span_request_header;
97pub mod query_consumer_offset_request_header;
98pub mod query_consumer_offset_response_header;
99pub mod query_correction_offset_header;
100pub mod query_message_request_header;
101pub mod query_message_response_header;
102pub mod query_subscription_by_consumer_request_header;
103pub mod query_topic_consume_by_who_request_header;
104pub mod query_topics_by_consumer_request_header;
105pub mod recall_message_request_header;
106pub mod recall_message_response_header;
107pub mod remove_broker_request_header;
108pub mod reply_message_request_header;
109pub mod reset_master_flush_offset_header;
110pub mod reset_offset_request_header;
111pub mod resume_check_half_message_request_header;
112pub mod search_offset_request_header;
113pub mod search_offset_response_header;
114pub mod trigger_lite_dispatch_request_header;
115pub mod unlock_batch_mq_request_header;
116pub mod unregister_client_request_header;
117pub mod update_acl_request_header;
118pub mod update_broker_config_request_header;
119pub mod update_broker_config_response_header;
120pub mod update_consumer_offset_conditional_header;
121pub mod update_consumer_offset_header;
122pub mod update_global_white_addrs_config_request_header;
123pub mod update_group_forbidden_request_header;
124pub mod update_subscription_group_config_cas_request_header;
125pub mod update_subscription_group_config_cas_response_header;
126pub mod update_topic_config_cas_request_header;
127pub mod update_topic_config_cas_response_header;
128pub mod update_user_request_header;
129pub mod view_broker_stats_data_request_header;
130pub mod view_message_request_header;
131pub mod view_message_response_header;
rocketmq_protocol/protocol/header.rs

rocketmq_protocol/protocol/
header.rs
