remove unused (#1771)

f1shl3gs · Jun 3, 2024 · e021e5d · e021e5d
1 parent a128ac7
commit e021e5d
Show file tree

Hide file tree

Showing 4 changed files with 1 addition and 137 deletions.
diff --git a/lib/framework/src/common/mod.rs b/lib/framework/src/common/mod.rs
diff --git a/lib/framework/src/common/open.rs b/lib/framework/src/common/open.rs
diff --git a/lib/framework/src/lib.rs b/lib/framework/src/lib.rs
@@ -4,7 +4,6 @@
 
 pub mod async_read;
 pub mod batch;
-mod common;
 pub mod config;
 pub mod dns;
 mod extension;
@@ -33,7 +32,6 @@ mod utilization;
 
 use std::sync::OnceLock;
 
-pub use common::*;
 pub use extension::Extension;
 pub use pipeline::Pipeline;
 pub use shutdown::*;

diff --git a/lib/framework/src/sink/util/tcp.rs b/lib/framework/src/sink/util/tcp.rs
@@ -25,7 +25,7 @@ use crate::sink::util::socket_bytes_sink::{BytesSink, ShutdownCheck};
 use crate::sink::VecSinkExt;
 use crate::tcp::TcpKeepaliveConfig;
 use crate::tls::{MaybeTlsStream, TlsConfig, TlsError};
-use crate::{dns, Healthcheck, OpenGauge, Sink, StreamSink};
+use crate::{dns, Healthcheck, Sink, StreamSink};
 
 #[derive(Debug, Error)]
 enum TcpError {
@@ -313,7 +313,6 @@ where
 
         while Pin::new(&mut input).peek().await.is_some() {
             let mut sink = self.connect().await;
-            let _open_token = OpenGauge::new();
 
             let result = match sink.send_all_peekable(&mut (&mut input).peekable()).await {
                 Ok(()) => sink.close().await,