rrpack-prime 0.41.0

RillRate Pack: Prime
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

use super::state::*;
use derive_more::{Deref, DerefMut};
use rill_derive::TracerOpts;
use rill_protocol::flow::core::FlowMode;
use rrpack_basis::{AutoPath, BindedTracer};

#[derive(TracerOpts, Clone, Default)]
pub struct LiveTailOpts {
    // TODO: Add levels here (maybe)
}

impl From<LiveTailOpts> for LiveTailSpec {
    fn from(_opts: LiveTailOpts) -> Self {
        Self {}
    }
}

#[derive(Debug, Deref, DerefMut, Clone)]
pub struct LiveTail {
    tracer: BindedTracer<LiveTailState>,
}

impl LiveTail {
    pub fn new(
        auto_path: impl Into<AutoPath>,
        mode: FlowMode,
        spec: impl Into<LiveTailSpec>,
    ) -> Self {
        let tracer = BindedTracer::new(auto_path.into(), mode, spec.into());
        Self { tracer }
    }

    pub fn log(
        &self,
        module: impl Into<String>,
        level: impl Into<String>,
        timestamp: impl Into<String>,
        content: impl Into<String>,
    ) {
        let record = LogRecord {
            module: module.into(),
            level: level.into(),
            timestamp: timestamp.into(),
            content: content.into(),
        };
        let msg = LiveTailEvent::Add(record);
        self.tracer.send(msg, None);
    }

    pub fn log_now(
        &self,
        module: impl Into<String>,
        level: impl Into<String>,
        content: impl Into<String>,
    ) {
        let timestamp = chrono::Local::now().format("%F%T%.3f").to_string();
        let record = LogRecord {
            module: module.into(),
            level: level.into(),
            timestamp,
            content: content.into(),
        };
        let msg = LiveTailEvent::Add(record);
        self.tracer.send(msg, None);
    }
}