Merge pull request #481 from weibocom/unusedfeature

Unusedfeature

agent/src/init.rs

@@ -7,8 +7,6 @@ pub(super) fn init(ctx: &Context) {
     init_log(&ctx);
     init_local_ip(&ctx);
     start_metrics_register_task(ctx);
-    #[cfg(feature = "console-api")]
-    crate::console::start_console(ctx);
 
     #[cfg(feature = "http")]
     crate::http::start(ctx);

agent/src/main.rs

@@ -2,7 +2,6 @@ use ds::BrzMalloc;
 #[global_allocator]
 static GLOBAL: BrzMalloc = BrzMalloc {};
 
-mod console;
 mod http;
 mod prometheus;
 mod service;

protocol/Cargo.toml

@@ -47,6 +47,21 @@ paste = "1.0"
 [features]
 max_allowed_packet = []
 regex = ["dep:regex"]
+buffer-pool = []
+bigdecimal = []
+bigdecimal03 = []
+chrono = []
+rust_decimal = []
+time = []
+time03 = []
+uuid = []
+rustc_serialize = []
+native-tls = []
+rustls = []
+frunk = []
+nightly = []
+rustls-tls = []
+
 
 [dev-dependencies]
 proptest = "1.0"

protocol/src/kv/common/misc/raw/seq.rs

@@ -101,6 +101,7 @@ where
 }
 
 /// Representation of a serialized bytes.
+#[allow(dead_code)]
 pub trait SeqRepr {
     /// Maximum number of items in a sequence (depends on how lenght is stored).
     const MAX_LEN: usize;

protocol/src/kv/common/packets/binlog_request.rs

@@ -13,6 +13,7 @@ use super::{BinlogDumpFlags, Sid};
 /// Binlog request representation. Please consult MySql documentation.
 ///
 /// This struct is a helper builder for [`ComBinlogDump`] and [`ComBinlogDumpGtid`].
+#[allow(dead_code)]
 #[derive(Debug, Clone, Eq, PartialEq, Hash)]
 pub struct BinlogRequest<'a> {
     /// Server id of a slave.

protocol/src/kv/common/packets/mod.rs

@@ -2259,6 +2259,7 @@ define_const!(
     1
 );
 
+#[allow(dead_code)]
 #[derive(Debug, Clone, PartialEq)]
 pub struct ComStmtExecuteRequest<'a> {
     com_stmt_execute: ComStmtExecuteHeader,
@@ -2365,6 +2366,7 @@ define_header!(
     InvalidComStmtSendLongDataHeader
 );
 
+#[allow(dead_code)]
 #[derive(Debug, Clone, Eq, PartialEq)]
 pub struct ComStmtSendLongData {
     __header: ComStmtSendLongDataHeader,

protocol/src/kv/common/query_result.rs

@@ -491,6 +491,7 @@ impl<T: crate::kv::prelude::Protocol, S: Stream> Drop for ResultSet<'_, '_, T, S
     }
 }
 
+#[allow(dead_code)]
 #[derive(Debug, Clone, PartialEq)]
 pub struct SetColumns<'a> {
     inner: Option<&'a Arc<[Column]>>,

protocol/src/vector/query_result.rs

@@ -7,7 +7,7 @@ pub use crate::kv::common::proto::Text;
 use super::packet::MysqlRawPacket;
 use crate::kv::common::{io::ParseBuf, packets::OkPacket, row::RowDeserializer};
 
-use std::{marker::PhantomData, sync::Arc};
+use std::marker::PhantomData;
 
 use crate::kv::common::packets::{Column, OldEofPacket, ResultSetTerminator};
 use crate::kv::common::query_result::{Or, SetIteratorState};
@@ -181,11 +181,6 @@ impl<T: crate::kv::prelude::Protocol> QueryResult<T> {
     }
 }
 
-#[derive(Debug, Clone, PartialEq)]
-pub struct SetColumns<'a> {
-    inner: Option<&'a Arc<[Column]>>,
-}
-
 #[inline]
 pub fn format_to_redis(rows: &Vec<Row>) -> Vec<u8> {
     let mut data = Vec::with_capacity(32 * rows.len());

stream/Cargo.toml

@@ -22,3 +22,6 @@ array-init = "2"
 ctor = "0.1.23"
 
 tokio.workspace = true
+
+[features]
+trace = []

tests/Cargo.toml

@@ -17,13 +17,13 @@ rand = "0.8.5"
 md5 = "*"
 byteorder = "1.4.3"
 assert-panic = "1.0.1"
-metrics = { path = "../metrics", features = ["mock-local-ip"]}
+metrics = { path = "../metrics", features = ["mock-local-ip"] }
 endpoint = { path = "../endpoint" }
 context = { path = "../context" }
 
 tokio.workspace = true
 ctor = "0.1.23"
-mysql_async ="0.31.3"
+mysql_async = "0.31.3"
 chrono = "0.4"
 lazy_static = "*"
 
@@ -54,3 +54,5 @@ layout-min = ["ds/tsc"]
 layout-max = ["rt/poll-io-metrics"]
 regex = ["protocol/regex"]
 github_workflow = []
+time = []
+nightly = []

tests/src/all.rs

@@ -32,5 +32,4 @@ mod proto_hook;
 mod ring_buffer;
 mod select;
 mod shard_checker;
-mod time;
 mod tx_buffer;

tests_integration/src/all.rs

@@ -1,4 +1,3 @@
-mod api;
 mod ci;
 mod counterservice;
 // mod hasher;