From 92dfbd490c492f30ba9350c160a74541c3e7a1a3 Mon Sep 17 00:00:00 2001 From: Tamipes Date: Wed, 3 Dec 2025 22:58:01 +0100 Subject: [PATCH] chore: small cleanup --- src/main.rs | 9 +++------ src/packets/mod.rs | 2 ++ 2 files changed, 5 insertions(+), 6 deletions(-) diff --git a/src/main.rs b/src/main.rs index 7895658..3e101d8 100644 --- a/src/main.rs +++ b/src/main.rs @@ -1,6 +1,3 @@ -//! This is a simple imitation of the basic functionality of kubectl: -//! kubectl {get, delete, apply, watch, edit} [name] -//! with labels and namespace selectors supported. use std::{net::SocketAddr, sync::Arc}; use futures::TryFutureExt; @@ -27,7 +24,7 @@ async fn main() { let fmt_layer = tracing_subscriber::fmt::layer() .with_target(false) .with_level(true); - let filter_layer = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info")); // default to INFO + let filter_layer = EnvFilter::try_from_default_env().unwrap_or_else(|_| EnvFilter::new("info")); tracing_subscriber::registry() .with(fmt_layer) .with(filter_layer) @@ -55,10 +52,10 @@ async fn main() { ); if let Err(e) = process_connection(socket, addr, acc).await { tracing::error!( - message = format!("Client disconnected"), // addr = format!("{}:{}", addr.ip().to_string(), addr.port().to_string()), trace = format!("{}", e.get_span_trace()), - err = format!("{}", e.context) + err = format!("{}", e.context), + "Client disconnected" ); } else { tracing::debug!( diff --git a/src/packets/mod.rs b/src/packets/mod.rs index 6785fe8..e255ec5 100644 --- a/src/packets/mod.rs +++ b/src/packets/mod.rs @@ -1,5 +1,7 @@ // use std::io::{self, Read, Write}; +use std::fmt; + use tokio::io; use tokio::io::AsyncReadExt; use tokio::io::AsyncWriteExt;