rocketmq_protocol/protocol/
body.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 broker_body;
16pub mod consumer_running_info;
17pub mod controller_rollout;
18pub mod controller_write_lease;
19pub mod create_topic_list_request_body;
20pub mod delete_subscription_group_list_request_body;
21pub mod delete_topic_list_request_body;
22pub mod get_broker_lite_info_response_body;
23pub mod get_consumer_list_by_group_response_body;
24pub mod get_lite_client_info_response_body;
25pub mod get_lite_group_info_response_body;
26pub mod get_lite_topic_info_response_body;
27pub mod get_parent_topic_info_response_body;
28
29pub mod consumer_connection;
30
31pub mod acl_info;
32pub mod batch_ack;
33pub mod batch_ack_builder;
34pub mod batch_ack_message_request_body;
35pub mod broker_replicas_info;
36pub mod broker_stats_item;
37pub mod check_client_request_body;
38pub mod check_rocksdb_cqwrite_progress_response_body;
39pub mod cluster_acl_version_info;
40pub mod cm_result;
41pub mod connection;
42pub mod consume_by_who;
43pub mod consume_message_directly_result;
44pub mod consume_queue_data;
45pub mod consume_status;
46pub mod consumer_offset_serialize_wrapper;
47pub mod elect_master_response_body;
48pub mod epoch_entry_cache;
49pub mod group_list;
50pub mod ha_client_runtime_info;
51pub mod ha_connection_runtime_info;
52pub mod ha_runtime_info;
53pub mod kv_table;
54pub mod lite_lag_info;
55pub mod lite_subscription_ctl_request_body;
56pub mod message_codec;
57pub mod message_request_mode_serialize_wrapper;
58pub mod pop_process_queue_info;
59pub mod process_queue_info;
60pub mod producer_connection;
61pub mod producer_info;
62pub mod producer_table_info;
63pub mod proxy_drain;
64pub mod query_assignment_request_body;
65pub mod query_assignment_response_body;
66pub mod query_consume_queue_response_body;
67pub mod query_consume_time_span_body;
68pub mod query_correction_offset_body;
69pub mod query_subscription_response_body;
70pub mod queue_time_span;
71pub mod release_checkpoint;
72pub mod request;
73pub mod response;
74pub mod set_message_request_mode_request_body;
75pub mod subscription_group_list;
76pub mod subscription_group_wrapper;
77pub mod supervised_mutation;
78pub mod sync_state_set_body;
79pub mod timer_metrics_serialize_wrapper;
80pub mod topic;
81pub mod topic_info_wrapper;
82pub mod unlock_batch_request_body;
83pub mod user_info;
rocketmq_protocol/protocol/body.rs

rocketmq_protocol/protocol/
body.rs
