Struct InstrumentedSink 

pub struct InstrumentedSink<'a, S>
where
    S: Sink + ?Sized,
{ /* private fields */ }

Wraps a &dyn Sink (or any &S: Sink) and emits spans + metrics around write_batch and flush. Constructed by Pipeline::run.

Implementations

impl<'a, S> InstrumentedSink<'a, S>

where S: Sink + ?Sized,

pub fn new(inner: &'a S, labels: Labels) -> InstrumentedSink<'a, S>

Trait Implementations

impl<'a, S> Sink for InstrumentedSink<'a, S>

where S: Sink + ?Sized,

fn connector_name(&self) -> &'static str

Stable identifier used as the connector label on metrics and the connector attribute on spans. See Source::connector_name.

fn write_batch<'life0, 'life1, 'async_trait>( &'life0 self, records: &'life1 [Value], ) -> Pin<Box<dyn Future<Output = Result<usize, FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InstrumentedSink<'a, S>: 'async_trait,

Write a batch of records to the destination.

fn write_batch_partial<'life0, 'life1, 'async_trait>( &'life0 self, records: &'life1 [Value], ) -> Pin<Box<dyn Future<Output = Result<Vec<Result<(), FaucetError>>, FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, InstrumentedSink<'a, S>: 'async_trait,

Write a batch and report per-row outcomes.

fn flush<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, InstrumentedSink<'a, S>: 'async_trait,

Flush any buffered data to the destination.

fn config_schema(&self) -> Value

Return a JSON Schema describing the configuration this sink accepts.

fn check<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 CheckContext, ) -> Pin<Box<dyn Future<Output = Result<CheckReport, FaucetError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Run a fast, non-mutating preflight probe (used by faucet doctor).