entrace_core: strip dependencies, 0.1.1 -> 0.1.2

the fully removed dependencies are still pulled in transitively, but not
explicitly, except for crossbeam, which is gone except for channel.

this should reduce compile time of an empty project with just
entrace_core as a dependency from ~6.5s to ~4.7s

Author: algorithmiker

Cargo.lock

@@ -1,23 +1,20 @@
 [package]
 name = "entrace_core"
 description = "client library for ENTRACE, a modern log viewer and observability toolkit for Rust"
-version = "0.1.1"
+version = "0.1.2"
 edition = "2024"
 license = "MIT OR Apache-2.0"
 repository = "https://github.com/algorithmiker/entrace"
 categories = ["development-tools::debugging"]
+
 [dependencies]
 bincode = { version = "2.0.1", features = ["serde"] }
-crossbeam = "0.8.4"
-derive_more = { version = "2.0.1", features = ["display"] }
+crossbeam-channel = "0.5.15"
 memmap2 = {version = "0.9.7", optional = true }
-mio = { version = "1.0.3", features = ["os-poll", "net"] }
 notify = {version = "8.1.0", optional = true }
-# free because tracing-subscriber already pulls it in
-nu-ansi-term = "0.50.1"
 serde = { version = "1.0.219", features = ["derive"] }
 thiserror = "2.0.12"
-tracing = "0.1.41"
+tracing = { version = "0.1.41", default-features = false }
 tracing-subscriber = "0.3.19"
 
 [dev-dependencies]

entrace_core/Cargo.toml

@@ -238,7 +238,7 @@ impl Default for IETLoadConfig {
 }
 
 pub struct IETPresentationConfig<R: Refresh = DummyRefresher> {
-    pub event_tx: Option<crossbeam::channel::Sender<IETEvent>>,
+    pub event_tx: Option<crossbeam_channel::Sender<IETEvent>>,
     pub refresher: R,
 }
 impl Default for IETPresentationConfig {
@@ -247,7 +247,7 @@ impl Default for IETPresentationConfig {
     }
 }
 impl<R: Refresh> IETPresentationConfig<R> {
-    pub fn new(event_tx: Option<crossbeam::channel::Sender<IETEvent>>, refresher: R) -> Self {
+    pub fn new(event_tx: Option<crossbeam_channel::Sender<IETEvent>>, refresher: R) -> Self {
         Self { event_tx, refresher }
     }
 }

entrace_core/src/lib.rs

@@ -43,15 +43,15 @@ pub trait FileLike: Read + Write + Seek {}
 impl<T: Read + Write + Seek> FileLike for T {}
 pub type ETResult<A, T> = Result<A, ETStorageError<T>>;
 pub struct ETStorage<T: FileLike, Q: FileLike + Send> {
-    pub sender: crossbeam::channel::Sender<Message<Q>>,
+    pub sender: crossbeam_channel::Sender<Message<Q>>,
     pub thread_handle: RwLock<Option<JoinHandle<ETResult<ETShutdownValue<T, Q>, T>>>>,
 }
 impl<T: FileLike + Send + 'static, Q: FileLike + Send + 'static> ETStorage<T, Q> {
     pub fn init(mut file: T) -> Self
     where
         Self: std::marker::Sized,
     {
-        let (tx, rx) = crossbeam::channel::unbounded::<Message<Q>>();
+        let (tx, rx) = crossbeam_channel::unbounded::<Message<Q>>();
         let thread_handle = std::thread::spawn(move || {
             let magic = entrace_magic_for(1, crate::StorageFormat::IET);
             file.write_all(&magic).unwrap();

entrace_core/src/mmap/et_storage.rs

@@ -11,7 +11,7 @@ use std::{
 };
 
 use bincode::error::DecodeError;
-use crossbeam::channel::Sender;
+use crossbeam_channel::Sender;
 use tracing::trace;
 use tracing::{error, info};
 
@@ -139,7 +139,7 @@ impl FileIETLogProvider {
                     {
                         if let Some(etx) = &config2.event_tx {
                             use crate::remote::IETEvent;
-                            etx.send(IETEvent::Error(FileIETError::NeedNotify.into()));
+                            etx.send(IETEvent::Error(FileIETError::NeedNotify.into())).ok();
                         }
                         return;
                     }

entrace_core/src/remote/file_iet_log_provider.rs

@@ -1,11 +1,11 @@
-use std::{thread::JoinHandle, time::Duration};
+use std::{fmt::Display, thread::JoinHandle, time::Duration};
 
 use crate::{
     Header, IETPresentationConfig, LevelContainer, MetadataRefContainer, PoolEntry, TraceEntry,
     log_provider::{LogProvider, LogProviderError, LogProviderResult},
     tree_layer::EnValueRef,
 };
-use crossbeam::channel::{Receiver, Sender};
+use crossbeam_channel::{Receiver, Sender};
 
 mod file_iet_log_provider;
 pub use file_iet_log_provider::*;
@@ -14,15 +14,21 @@ pub use remote_storage::*;
 mod remote_log_provider;
 pub use remote_log_provider::*;
 
-#[derive(derive_more::Display)]
 pub enum IETInfo {
-    #[display("Server started, waiting for connections")]
     ServerStarted,
-    #[display("Received connection")]
     ReceivedConnection,
-    #[display("Remote client closed connection")]
     RemoteClosedConnection,
 }
+impl Display for IETInfo {
+    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
+        match self {
+            IETInfo::ServerStarted => write!(f, "Server started, waiting for connections"),
+            IETInfo::ReceivedConnection => write!(f, "Received connection"),
+            IETInfo::RemoteClosedConnection => write!(f, "Remote client closed connection"),
+        }
+    }
+}
+
 pub enum IETEvent {
     Error(LogProviderError),
     Info(IETInfo),
@@ -55,7 +61,7 @@ impl BaseIETLogProvider {
         // Notifier: Notify + Send + 'static,
         // Refresher: Refresh + Send + 'static,
     {
-        let (tx, rx) = crossbeam::channel::unbounded();
+        let (tx, rx) = crossbeam_channel::unbounded();
         let handle = std::thread::spawn(move || worker_thread(buf, tx, config));
         // no root data entry here, the client has to send it.
         Self { handle, receiver: rx, pool: vec![], data: vec![] }
@@ -134,8 +140,8 @@ impl LogProvider for BaseIETLogProvider {
                     }
                 }
                 Err(y) => match y {
-                    crossbeam::channel::TryRecvError::Empty => (),
-                    crossbeam::channel::TryRecvError::Disconnected => (),
+                    crossbeam_channel::TryRecvError::Empty => (),
+                    crossbeam_channel::TryRecvError::Disconnected => (),
                 },
             }
         }

entrace_core/src/remote/mod.rs

@@ -13,15 +13,15 @@ use crate::{
     log_provider::{LogProvider, LogProviderResult},
     remote::{BaseIETLogProvider, MainThreadMessage, Refresh},
 };
-use crossbeam::channel::Sender;
+use crossbeam_channel::Sender;
 
 enum ReadState {
     WantMagic,
     WantMessage,
 }
 
 struct RemoteWorkerState<'a, R: Refresh> {
-    event_tx: Option<crossbeam::channel::Sender<IETEvent>>,
+    event_tx: Option<crossbeam_channel::Sender<IETEvent>>,
     refresher: R,
     reader: BufReader<&'a mut TcpStream>,
     tx: Sender<MainThreadMessage>,
@@ -31,7 +31,7 @@ struct RemoteWorkerState<'a, R: Refresh> {
 }
 impl<'a, R: Refresh> RemoteWorkerState<'a, R> {
     pub fn new(
-        event_tx: Option<crossbeam::channel::Sender<IETEvent>>, refresher: R,
+        event_tx: Option<crossbeam_channel::Sender<IETEvent>>, refresher: R,
         reader: BufReader<&'a mut TcpStream>, tx: Sender<MainThreadMessage>, read_state: ReadState,
     ) -> RemoteWorkerState<'a, R> {
         Self {

entrace_core/src/remote/remote_log_provider.rs

@@ -1,5 +1,5 @@
 use crate::{StorageFormat, TraceEntry, entrace_magic_for, storage::Storage, tree_layer::EnValue};
-use crossbeam::channel::{SendError, Sender};
+use crossbeam_channel::{SendError, Sender};
 use std::{any::Any, io::Write, sync::RwLock, thread::JoinHandle};
 
 pub enum RemoteMessage {
@@ -40,7 +40,7 @@ pub struct IETStorage<T: Write + Send + 'static> {
 }
 impl<T: Write + Send + 'static> IETStorage<T> {
     pub fn init(mut config: IETStorageConfig<T>) -> Self {
-        let (tx, rx) = crossbeam::channel::unbounded();
+        let (tx, rx) = crossbeam_channel::unbounded();
         let format =
             if config.length_prefixed { StorageFormat::IETPrefix } else { StorageFormat::IET };
         let thread_handle = std::thread::spawn(move || {

entrace_core/src/remote/remote_storage.rs

@@ -1,6 +1,6 @@
 [package]
 name = "entrace_example"
-version = "0.1.1"
+version = "0.1.2"
 edition = "2021"
 license = "MIT OR Apache-2.0"
 

example/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "entrace_gui"
-version = "0.1.1"
+version = "0.1.2"
 edition = "2024"
 license = "(MIT OR Apache-2.0) AND OFL-1.1"