Trait Sink 

pub trait Sink:
    Send
    + Sync
    + 'static {
    // Required method
    fn deliver(&self, env: ScrubbedEnvelope<'_>);

    // Provided methods
    fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>> { ... }
    fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>> { ... }
}

A delivery destination. Called from per-tier worker tasks, never on the emit thread.

Required Methods

fn deliver(&self, env: ScrubbedEnvelope<'_>)

Hand the envelope to the sink. Must not block; long IO is queued internally. Spec 11 § 4 / spec 14 § 5.

Provided Methods

fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Flush in-flight batches; awaits IO if needed.

fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Shut down (drain + close). Idempotent.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl Sink for OtlpLogSink

fn deliver(&self, env: ScrubbedEnvelope<'_>)

fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

impl Sink for OtlpMetricSink

fn deliver(&self, env: ScrubbedEnvelope<'_>)

fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

impl Sink for OtlpTraceSink

fn deliver(&self, env: ScrubbedEnvelope<'_>)

fn flush(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

fn shutdown(&self) -> Pin<Box<dyn Future<Output = ()> + Send + '_>>

Implementors

impl Sink for FanOutSink

impl Sink for InMemorySink

impl Sink for NdjsonFileSink

impl Sink for NoopSink

impl Sink for StdoutSink