Skip to main content

EventSink

codex_runtime::runtime::sink

Trait EventSink 

Source 
pub trait EventSink:
    Send
    + Sync
    + 'static {
    // Required method
    fn on_envelope<'a>(&'a self, envelope: &'a Envelope) -> EventSinkFuture<'a>;
}
Expand description

Optional event persistence/export hook. Implementations should avoid panics and return SinkError on write failures.

Required Methods§

Source

fn on_envelope<'a>(&'a self, envelope: &'a Envelope) -> EventSinkFuture<'a>

Consume one envelope. Side effects: sink-specific I/O. Complexity depends on implementation.

Implementors§