obs-kit 0.2.1

Façade for the obs observability SDK; re-exports the everyday API (init, observer, sinks, macros).
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

//! End-to-end test: `StandardObserver` with the per-tier worker pool
//! delivers an envelope to a sink. Spec 11 §§ 4 + 4.1 (pipeline order).

use std::sync::Arc;

use obs_kit::{InMemorySink, Observer, StandardObserver, Tier};

#[tokio::test(flavor = "multi_thread", worker_threads = 2)]
async fn test_worker_pool_should_deliver_to_log_sink() {
    let sink = InMemorySink::new();
    let handle = sink.handle();
    let observer = StandardObserver::builder()
        .service("worker-pool", "0.0.0")
        .filter("info")
        .sink_for(Tier::Log, Arc::new(sink))
        .build()
        .unwrap();

    let env = obs_kit::ObsEnvelope {
        full_name: "test.v1.WorkerPool".to_string(),
        tier: ::obs_kit::__private::EnumValue::Known(::obs_kit::__private::ProtoTier::TIER_LOG),
        sev: ::obs_kit::__private::EnumValue::Known(
            ::obs_kit::__private::ProtoSeverity::SEVERITY_INFO,
        ),
        ..Default::default()
    };
    observer.emit_envelope(env);
    observer.flush().await;
    // Yield once more so the spawned worker drains anything still in
    // its mpsc.
    tokio::time::sleep(std::time::Duration::from_millis(100)).await;

    let drained = handle.snapshot();
    assert_eq!(drained.len(), 1, "worker pool should deliver one envelope");
    assert_eq!(drained[0].full_name, "test.v1.WorkerPool");
    observer.shutdown().await;
}