rocketmq_common/
lib.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
15#![allow(dead_code)]
16#![allow(unused_imports)]
17#![feature(sync_unsafe_cell)]
18#![allow(unused_variables)]
19
20use std::borrow::Borrow;
21use std::cell::SyncUnsafeCell;
22use std::hash::Hash;
23use std::hash::Hasher;
24use std::ops::Deref;
25use std::ops::DerefMut;
26use std::sync::Arc;
27use std::sync::Weak;
28
29pub use rocketmq_error::RocketMQError;
30pub use rocketmq_error::RocketMQResult;
31
32pub use crate::common::attribute::topic_attributes as TopicAttributes;
33pub use crate::common::lite::belongs_to;
34pub use crate::common::lite::get_lite_topic;
35pub use crate::common::lite::get_parent_and_lite_topic;
36pub use crate::common::lite::get_parent_topic;
37pub use crate::common::lite::is_lite_topic_queue;
38pub use crate::common::lite::to_lmq_name;
39pub use crate::common::lite::OffsetOption;
40pub use crate::common::lite::OffsetOptionType;
41pub use crate::common::lite::LITE_TOPIC_PREFIX;
42pub use crate::common::lite::SEPARATOR;
43pub use crate::common::message::message_accessor as MessageAccessor;
44pub use crate::common::message::message_decoder as MessageDecoder;
45pub use crate::common::mq_version::RocketMqVersion as RocketMQVersion;
46pub use crate::common::producer::recall_message_handle::HandleV1 as RecallMessageHandleV1;
47pub use crate::common::producer::recall_message_handle::RecallMessageHandle;
48pub use crate::thread_pool::FuturesExecutorService;
49pub use crate::thread_pool::FuturesExecutorServiceBuilder;
50pub use crate::thread_pool::ScheduledExecutorService;
51pub use crate::thread_pool::TokioExecutorService;
52pub use crate::utils::cleanup_policy_utils as CleanupPolicyUtils;
53pub use crate::utils::crc32_utils as CRC32Utils;
54pub use crate::utils::env_utils as EnvUtils;
55pub use crate::utils::file_utils as FileUtils;
56pub use crate::utils::message_utils as MessageUtils;
57pub use crate::utils::parse_config_file as ParseConfigFile;
58pub use crate::utils::time_utils as TimeUtils;
59pub use crate::utils::util_all as UtilAll;
60
61pub mod common;
62pub mod error;
63pub mod log;
64mod thread_pool;
65pub mod utils;
rocketmq_common/lib.rs

rocketmq_common/
lib.rs
