Struct ObservationSink 

pub struct ObservationSink<'a> { /* private fields */ }

Where a payload projector writes its observation facts.

A projector reads verdicts, ids and error envelopes off a raw payload before normalization discards them. Text it forwards must go through Self::scrub: a payload can echo credentials.

Usage is not a projector’s to report: the driver observes it once, from the usage the decoder normalized into the reply’s end.

use rig_core::wire::{AdapterEvent, AdapterUsage, ObservationSink};

// A projector cannot parse usage a second time off the raw payload.
fn project(sink: &mut ObservationSink<'_>) {
    sink.emit(AdapterEvent::Usage {
        usage: AdapterUsage::default(),
    });
}

Implementations

impl ObservationSink<'_>

pub fn error(&mut self, error: AdapterErrorEnvelope)

Record the provider’s error envelope.

pub fn provider(&mut self, verdict: AdapterVerdict, response_id: Option<String>)

Record the provider’s verdict, and the response id it named.

pub fn scrub(&self, value: &str) -> String

Bound and redact diagnostic text from the payload.