stasis-rs 0.6.0

Durable AI orchestration framework with runtime jobs, lineage, and memory integration
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

use crate::infrastructure::runtime::noop_runtime_metrics::NoopRuntimeMetrics;
use crate::ports::outbound::runtime::runtime_metrics::RuntimeMetrics;
use crate::ports::outbound::runtime::runtime_tracing::{
    OtelAttribute, RuntimeTracing, SpanGuard, TraceContext,
};

#[derive(Clone, Copy, Debug, Default)]
pub struct NoopRuntimeTracing;

impl RuntimeTracing for NoopRuntimeTracing {
    fn start_span(&self, _name: &'static str, _attributes: &[OtelAttribute]) -> SpanGuard {
        SpanGuard::noop()
    }

    fn start_span_with_trace_context(
        &self,
        name: &'static str,
        attributes: &[OtelAttribute],
        _parent: Option<&TraceContext>,
    ) -> SpanGuard {
        self.start_span(name, attributes)
    }

    fn active_trace_context(&self) -> Option<TraceContext> {
        None
    }
}

#[derive(Clone, Copy, Debug, Default)]
pub struct NoopRuntimeTelemetry;

impl RuntimeMetrics for NoopRuntimeTelemetry {
    fn incr_counter(&self, name: &str, value: u64) {
        NoopRuntimeMetrics.incr_counter(name, value);
    }

    fn observe_duration_ms(&self, name: &str, duration_ms: u64) {
        NoopRuntimeMetrics.observe_duration_ms(name, duration_ms);
    }
}

impl RuntimeTracing for NoopRuntimeTelemetry {
    fn start_span(&self, name: &'static str, attributes: &[OtelAttribute]) -> SpanGuard {
        NoopRuntimeTracing.start_span(name, attributes)
    }

    fn start_span_with_trace_context(
        &self,
        name: &'static str,
        attributes: &[OtelAttribute],
        parent: Option<&TraceContext>,
    ) -> SpanGuard {
        NoopRuntimeTracing.start_span_with_trace_context(name, attributes, parent)
    }

    fn active_trace_context(&self) -> Option<TraceContext> {
        None
    }
}