Struct StreamInstrumentationRun 

pub struct StreamInstrumentationRun { /* private fields */ }

Handle for updating one instrumented materialization.

Implementations

impl StreamInstrumentationRun

pub fn id(&self) -> StreamInstrumentationId

The id assigned by the registry.

pub fn record_element(&self)

Record one successfully observed element.

pub fn record_elements(&self, elements: u64)

Record multiple successfully observed elements.

pub fn record_restart(&self)

Record one restart for this materialization/job owner.

pub fn record_restarts(&self, restarts: u64)

Record multiple restarts for this materialization/job owner.

pub fn mark_running(&self)

Mark the run as running.

pub fn mark_draining(&self)

Mark the run as draining.

pub fn mark_completed(&self)

Mark the run as completed.

pub fn mark_failed(&self)

Mark the run as failed.

pub fn snapshot(&self) -> StreamInstrumentationSnapshot

Return a point-in-time snapshot of this run.

Trait Implementations

impl Clone for StreamInstrumentationRun

fn clone(&self) -> StreamInstrumentationRun

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamInstrumentationRun

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

Formats the value using the given formatter.