Trait WriteOne 

pub trait WriteOne: Send + Sync {
    // Required methods
    fn id(&self) -> &str;
    fn write<'life0, 'life1, 'async_trait>(
        &'life0 self,
        env: &'life1 Envelope,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Ergonomic sink: “write one envelope, report result”.

ManagedSink turns a WriteOne into a Sink with the standard recv loop, cancellation, error policy, and optional retry with exponential back-off. Cross-cutting wrappers (rate limiting, batching) compose over WriteOne the same way and plug into ManagedSink unchanged.

Required Methods

fn id(&self) -> &str

fn write<'life0, 'life1, 'async_trait>( &'life0 self, env: &'life1 Envelope, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Implementors

impl WriteOne for ApiSink

impl WriteOne for FileSink

impl WriteOne for KafkaSink

impl WriteOne for SqlSink