disyn-runtime 0.1.0

Budget manager, telemetry, and shell executor for the disyn agent pipeline
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

use disyn_core::ports::{SpanEvent, TelemetrySink};

pub struct TracingSink;

impl Default for TracingSink {
    fn default() -> Self {
        Self
    }
}

impl TracingSink {
    pub fn init() -> Self {
        Self
    }
}

impl TelemetrySink for TracingSink {
    fn emit(&self, event: &SpanEvent) {
        tracing::info!(
            trace_id = %event.trace_id,
            kind = ?event.kind,
            duration_ms = event.duration_ms,
            status = ?event.status,
            "span"
        );
    }
}