arpx/runtime/job/task/log_monitor/
message.rs

1#[derive(Clone)]
2pub enum LogMonitorCmd {
3    Close,
4    Log,
5    None,
6}
7
8#[derive(Clone)]
9pub struct LogMonitorMessage {
10    pub cmd: LogMonitorCmd,
11    pub message: String,
12}
13
14impl Default for LogMonitorMessage {
15    fn default() -> Self {
16        Self::new()
17    }
18}
19
20impl LogMonitorMessage {
21    pub fn new() -> Self {
22        Self {
23            cmd: LogMonitorCmd::None,
24            message: "Empty message.".to_owned(),
25        }
26    }
27
28    pub fn cmd(mut self, c: LogMonitorCmd) -> Self {
29        self.cmd = c;
30
31        self
32    }
33
34    pub fn message(mut self, m: String) -> Self {
35        self.message = m;
36
37        self
38    }
39}