rocketmq-remoting 0.9.0

Rust implementation of Apache rocketmq remoting
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

// Copyright 2023 The RocketMQ Rust Authors
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

pub mod broker_body;
pub mod consumer_running_info;
pub mod create_topic_list_request_body;
pub mod get_broker_lite_info_response_body;
pub mod get_consumer_list_by_group_response_body;
pub mod get_lite_client_info_response_body;
pub mod get_lite_group_info_response_body;
pub mod get_lite_topic_info_response_body;
pub mod get_parent_topic_info_response_body;

pub mod consumer_connection;

pub mod acl_info;
pub mod batch_ack;
pub mod batch_ack_message_request_body;
pub mod broker_replicas_info;
pub mod broker_stats_item;
pub mod check_client_request_body;
pub mod check_rocksdb_cqwrite_progress_response_body;
pub mod cluster_acl_version_info;
pub mod cm_result;
pub mod connection;
pub mod consume_by_who;
pub mod consume_message_directly_result;
pub mod consume_queue_data;
pub mod consume_status;
pub mod consumer_offset_serialize_wrapper;
pub mod elect_master_response_body;
pub mod epoch_entry_cache;
pub mod group_list;
pub mod ha_client_runtime_info;
pub mod ha_connection_runtime_info;
pub mod ha_runtime_info;
pub mod kv_table;
pub mod lite_lag_info;
pub mod lite_subscription_ctl_request_body;
pub mod message_request_mode_serialize_wrapper;
pub mod pop_process_queue_info;
pub mod process_queue_info;
pub mod producer_connection;
pub mod producer_info;
pub mod producer_table_info;
pub mod query_assignment_request_body;
pub mod query_assignment_response_body;
pub mod query_consume_queue_response_body;
pub mod query_consume_time_span_body;
pub mod query_correction_offset_body;
pub mod query_subscription_response_body;
pub mod queue_time_span;
pub mod request;
pub mod response;
pub mod set_message_request_mode_request_body;
pub mod subscription_group_list;
pub mod subscription_group_wrapper;
pub mod sync_state_set_body;
pub mod timer_metrics_serialize_wrapper;
pub mod topic;
pub mod topic_info_wrapper;
pub mod unlock_batch_request_body;
pub mod user_info;