diff --git a/src/main.rs b/src/main.rs index a1d651d..098c56d 100644 --- a/src/main.rs +++ b/src/main.rs @@ -31,7 +31,7 @@ fn main() { checker.launch_workers::(5, Arc::new(check_handler)); checker.subscribe(receiver); - for i in 0..5000 { + for i in 0..500 { let message = Message::new(i, Subject::Action(JobAction::Deploy)); deployer.put_message(message); } diff --git a/src/message/message.rs b/src/message/message.rs index 62d0195..700bab4 100644 --- a/src/message/message.rs +++ b/src/message/message.rs @@ -1,6 +1,6 @@ use crate::model::JobAction; -#[derive(Debug, Clone, Copy)] +#[derive(Debug, Clone, Copy, PartialEq)] pub enum Subject { Action(JobAction), StopManager, diff --git a/src/model/job.rs b/src/model/job.rs index c045e3b..df644e8 100644 --- a/src/model/job.rs +++ b/src/model/job.rs @@ -4,7 +4,7 @@ use super::{Runner, RunnerStatus, Storer}; use crate::error::{MessageError, RunnerError, StorerError}; use crate::message::{Message, Subject}; -#[derive(Debug, Clone, Copy)] +#[derive(Debug, Clone, Copy, PartialEq)] pub enum JobAction { Deploy, Check,