Struct StreamInstrumentationRegistry 

pub struct StreamInstrumentationRegistry { /* private fields */ }

Cloneable registry handle for instrumented stream materializations.

The registry is not consulted by ordinary streams. It is only captured by streams that explicitly call Source::instrumented, and registration happens once per materialization.

Implementations

impl StreamInstrumentationRegistry

pub fn new() -> Self

Create an empty registry.

pub fn register(&self, name: impl Into<String>) -> StreamInstrumentationRun

Register one materialized stream run.

This is public so a future control plane can create a run handle for work it supervises directly. Most stream users should prefer Source::instrumented.

pub fn snapshot( &self, id: StreamInstrumentationId, ) -> Option<StreamInstrumentationSnapshot>

Return a snapshot for one materialized run, if it is still retained.

pub fn snapshots(&self) -> Vec<StreamInstrumentationSnapshot>

Return snapshots for every retained materialized run, ordered by id.

pub fn remove(&self, id: StreamInstrumentationId) -> bool

Drop a retained run from the registry.

Removing a run only affects future snapshots; existing StreamInstrumentationRun handles continue to own their counters.

Trait Implementations

impl Clone for StreamInstrumentationRegistry

fn clone(&self) -> StreamInstrumentationRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamInstrumentationRegistry

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

Formats the value using the given formatter.

impl Default for StreamInstrumentationRegistry

fn default() -> StreamInstrumentationRegistry

Returns the “default value” for a type.