Author: NikolaRHristov

Cargo.toml

@@ -1,23 +1,25 @@
 [build-dependencies]
-serde = { version = "1.0.219", features = ["derive"] }
-toml = { version = "0.8.20" }
+serde = { workspace = true }
+toml = { workspace = true }
+
 
 [dependencies]
-async-trait = "0.1.88"
-config = { version = "0.15.11" }
-dashmap = { version = "6.1.0" }
-env_logger = { version = "0.11.8" }
-futures = { version = "0.3.31" }
-log = { version = "0.4.27" }
-metrics = { version = "0.24.1" }
-rand = { version = "0.9.0" }
-serde = { version = "1.0.219", features = ["derive"] }
-serde_json = { version = "1.0.140" }
-thiserror = { version = "2.0.12" }
-tokio = { version = "1.44.2", features = ["full"] }
-tokio-console = { version = "0.1.13", optional = true }
-tokio-tungstenite = "0.26.2"
-unbug = { version = "0.4.0" }
+async_trait = { workspace = true }
+config = { workspace = true }
+dashmap = { workspace = true }
+env_logger = { workspace = true }
+futures = { workspace = true }
+log = { workspace = true }
+metrics = { workspace = true }
+rand = { workspace = true }
+serde = { workspace = true }
+serde_json = { workspace = true }
+thiserror = { workspace = true }
+tokio = { workspace = true }
+tokio_console = { workspace = true, optional = true }
+tokio_tungstenite = { workspace = true }
+unbug = { workspace = true }
+crossbeam_deque = { workspace = true }
 
 [[example]]
 name = "Sequence"

Source/Library.rs

@@ -8,8 +8,8 @@
 #![allow(non_snake_case, non_camel_case_types)]
 
 // --- Public API ---
-pub mod scheduler;
-pub mod task;
+pub mod Scheduler;
+pub mod Task;
 
 // --- Internal Implementation ---
-mod queue;
+mod Queue;

Source/Queue/StealingQueue.rs

@@ -4,7 +4,7 @@
 use crossbeam_deque::{Injector, Stealer, Worker};
 use rand::seq::SliceRandom;
 
-use crate::task::{Priority, Task};
+use crate::Task::{Priority, Task};
 
 /// A container for a set of queues for a single priority level.
 struct PriorityQueueSet {

Source/Queue/mod.rs

@@ -12,4 +12,4 @@ mod StealingQueue;
 // private from external consumers.
 // @see StealingQueue
 //
-pub(crate) use self::StealingQueue::StealingQueue;
+// pub(crate) use self::StealingQueue::StealingQueue;

Source/Scheduler/Scheduler.rs

@@ -15,9 +15,9 @@ use tokio::task::JoinHandle;
 /// queue, and task execution lifecycle.
 use super::Worker::Worker;
 use crate::{
-	queue::StealingQueue,
-	scheduler::SchedulerBuilder::Concurrency,
-	task::{Priority, Task},
+	Queue::StealingQueue,
+	Scheduler::SchedulerBuilder::Concurrency,
+	Task::{Priority, Task},
 };
 
 /// Manages a pool of worker threads and a work-stealing queue to execute tasks

Source/Scheduler/mod.rs

@@ -16,8 +16,8 @@ mod Worker;
 // The main scheduler struct that manages the worker pool and task execution.
 // @see Scheduler
 //
-pub use self::Scheduler::Scheduler;
+// pub use self::Scheduler::Scheduler;
 // The fluent builder for creating and configuring a `Scheduler` instance.
 // This is the primary entry point for using the Echo library.
 // @see SchedulerBuilder
-pub use self::SchedulerBuilder::SchedulerBuilder;
+// pub use self::SchedulerBuilder::SchedulerBuilder;