Skip to main content

Sink

obs_kit

Trait Sink 

Source 
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 + '_>> { ... }
}
Expand description

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

Required Methods§

Source

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§

Source

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

Flush in-flight batches; awaits IO if needed.

Source

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

Shut down (drain + close). Idempotent.

Implementors§