id_effect_opentelemetry 0.4.0

OpenTelemetry tracing and metrics integration for id_effect (Phase B / @effect/opentelemetry parity)
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

//! Capability DI provider for an installed OpenTelemetry runtime handle.

use std::sync::Arc;

use id_effect::{Cap, CapabilityId, CapabilityKey, Env, ProviderBox, ProviderError, ProviderNode};

use crate::starter::OtelStarterGuard;

/// OpenTelemetry runtime handle (flush/shutdown + meter access).
pub type OtelRuntime = Arc<OtelStarterGuard>;

/// Register `guard` in the capability environment for domain programs that need OTEL flush/shutdown.
#[inline]
pub fn provide_otel_runtime(guard: Arc<OtelStarterGuard>) -> ProviderBox {
  struct Node(Arc<OtelStarterGuard>);

  impl ProviderNode for Node {
    fn id(&self) -> &str {
      "opentelemetry/runtime"
    }

    fn requires(&self) -> &[CapabilityId] {
      &[]
    }

    fn provides(&self) -> CapabilityId {
      Cap::<OtelRuntime>::id()
    }

    fn cap_name(&self) -> &str {
      "OtelRuntime"
    }

    fn build(&self, deps: &Env) -> Result<Env, ProviderError> {
      let mut out = deps.clone();
      out.insert::<Cap<OtelRuntime>>(Arc::clone(&self.0));
      Ok(out)
    }
  }

  ProviderBox(Arc::new(Node(guard)))
}