relux-runtime 0.6.0

Internal: runtime for Relux. No semver guarantees.
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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89

//! Send / recv / sleep event emitters.
//!
//! These are the thinnest emitters in the builder: bytes moving in or
//! out of a PTY, plus the structural start/end of a `sleep` BIF call.

use std::time::Duration;

use relux_core::diagnostics::IrSpan;

use super::StructuredLogBuilder;
use crate::observe::progress::ProgressEvent;
use crate::observe::structured::event::EventKind;
use crate::observe::structured::span::SpanId;

impl StructuredLogBuilder {
    pub fn emit_send(
        &self,
        span: SpanId,
        shell: &str,
        marker: &str,
        data: &str,
        location: Option<&IrSpan>,
    ) {
        self.push_event(
            span,
            Some(shell),
            Some(marker),
            location,
            EventKind::Send {
                data: data.to_string(),
            },
        );
        self.push_progress(ProgressEvent::Send);
    }

    pub fn emit_recv(
        &self,
        span: SpanId,
        shell: &str,
        marker: &str,
        data: &str,
        location: Option<&IrSpan>,
    ) {
        self.push_event(
            span,
            Some(shell),
            Some(marker),
            location,
            EventKind::Recv {
                data: data.to_string(),
            },
        );
    }

    pub fn emit_sleep_start(
        &self,
        span: SpanId,
        shell: &str,
        marker: &str,
        duration: Duration,
        location: Option<&IrSpan>,
    ) {
        self.push_event(
            span,
            Some(shell),
            Some(marker),
            location,
            EventKind::SleepStart { duration },
        );
        self.push_progress(ProgressEvent::SleepStart);
    }

    pub fn emit_sleep_done(
        &self,
        span: SpanId,
        shell: &str,
        marker: &str,
        location: Option<&IrSpan>,
    ) {
        self.push_event(
            span,
            Some(shell),
            Some(marker),
            location,
            EventKind::SleepDone,
        );
        self.push_progress(ProgressEvent::SleepDone);
    }
}