rocketmq_common/
lib.rs

1/*
2 * Licensed to the Apache Software Foundation (ASF) under one or more
3 * contributor license agreements.  See the NOTICE file distributed with
4 * this work for additional information regarding copyright ownership.
5 * The ASF licenses this file to You under the Apache License, Version 2.0
6 * (the "License"); you may not use this file except in compliance with
7 * the License.  You may obtain a copy of the License at
8 *
9 *     http://www.apache.org/licenses/LICENSE-2.0
10 *
11 * Unless required by applicable law or agreed to in writing, software
12 * distributed under the License is distributed on an "AS IS" BASIS,
13 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 * See the License for the specific language governing permissions and
15 * limitations under the License.
16 */
17
18#![allow(dead_code)]
19#![allow(unused_imports)]
20#![feature(sync_unsafe_cell)]
21#![allow(unused_variables)]
22
23use std::borrow::Borrow;
24use std::cell::SyncUnsafeCell;
25use std::hash::Hash;
26use std::hash::Hasher;
27use std::ops::Deref;
28use std::ops::DerefMut;
29use std::sync::Arc;
30use std::sync::Weak;
31
32pub use crate::common::attribute::topic_attributes as TopicAttributes;
33pub use crate::common::message::message_accessor as MessageAccessor;
34pub use crate::common::message::message_decoder as MessageDecoder;
35pub use crate::common::mq_version::RocketMqVersion as RocketMQVersion;
36pub use crate::thread_pool::FuturesExecutorService;
37pub use crate::thread_pool::FuturesExecutorServiceBuilder;
38pub use crate::thread_pool::ScheduledExecutorService;
39pub use crate::thread_pool::TokioExecutorService;
40pub use crate::utils::cleanup_policy_utils as CleanupPolicyUtils;
41pub use crate::utils::crc32_utils as CRC32Utils;
42pub use crate::utils::env_utils as EnvUtils;
43pub use crate::utils::file_utils as FileUtils;
44pub use crate::utils::message_utils as MessageUtils;
45pub use crate::utils::parse_config_file as ParseConfigFile;
46pub use crate::utils::time_utils as TimeUtils;
47pub use crate::utils::util_all as UtilAll;
48
49pub mod common;
50pub mod error;
51pub mod log;
52mod thread_pool;
53pub mod utils;
rocketmq_common/lib.rs

rocketmq_common/
lib.rs
