Struct RecordingObserver 

pub struct RecordingObserver { /* private fields */ }

An observer that keeps everything it was given, for assertions in tests.

It is cheap, thread-safe and never panics: a poisoned lock is recovered rather than propagated, because a telemetry sink must not turn one test failure into a cascade.

use turnframe_core::ids::WorkflowKey;
use turnframe_core::observe::{Observer, Signal, SignalLabels};
use turnframe_telemetry::RecordingObserver;

let observer = RecordingObserver::new();
observer.observe_labeled(
    &Signal::CommandExecuted,
    &SignalLabels::workflow(WorkflowKey::from("trip")),
);

assert_eq!(observer.count(Signal::CommandExecuted), 1);
assert!(observer.contains(Signal::CommandExecuted));
assert_eq!(observer.labels_of(Signal::CommandExecuted).len(), 1);

Implementations

impl RecordingObserver

pub fn new() -> Self

An observer with nothing recorded yet.

pub fn records(&self) -> Vec<RecordedSignal>

Everything recorded so far, in arrival order.

pub fn signals(&self) -> Vec<Signal>

The signals recorded so far, in arrival order.

pub fn count(&self, signal: Signal) -> usize

How many times a signal was recorded.

pub fn contains(&self, signal: Signal) -> bool

Whether a signal was recorded at least once.

pub fn labels_of(&self, signal: Signal) -> Vec<SignalLabels>

The label sets a signal was recorded with, in arrival order.

pub fn durations_of(&self, signal: Signal) -> Vec<Duration>

The durations a latency signal was recorded with, in arrival order.

pub fn len(&self) -> usize

How many signals were recorded in total.

pub fn is_empty(&self) -> bool

Whether nothing was recorded.

pub fn clear(&self)

Drops everything recorded so far.

Trait Implementations

impl Debug for RecordingObserver

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RecordingObserver

fn default() -> Self

Returns the “default value” for a type.

impl Observer for RecordingObserver

fn observe(&self, signal: &Signal)

Observes a signal without labels.

fn observe_labeled(&self, signal: &Signal, labels: &SignalLabels)

Observes a signal with labels. The default drops the labels.

fn observe_duration( &self, signal: &Signal, duration: Duration, labels: &SignalLabels, )

Observes a duration signal (SignalKind::DurationMillis or SignalKind::DurationMicros) with its measured value. The default drops the value and forwards to Observer::observe_labeled.