Enum Sink 

pub enum Sink {
    Stdout(StdoutSink),
    File(FileSink),
    Webhook(Box<WebhookSink>),
    FanOut(Vec<Sink>),
}

Enum dispatch for output adapters.

Uses enum dispatch instead of dyn Trait because:

• Async trait methods are not object-safe
• FanOut(Vec<Sink>) requires a sized, concrete type

Variants

Stdout(StdoutSink)

Write NDJSON to stdout.

File(FileSink)

Append NDJSON to a file.

Webhook(Box<WebhookSink>)

Render and POST a templated HTTP request per result.

FanOut(Vec<Sink>)

Fan out to multiple sinks.

Implementations

impl Sink

pub fn send<'a>( &'a mut self, result: &'a ProcessResult, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'a>>

Serialize and deliver a ProcessResult to this sink.

Synchronous sinks (Stdout, File) use block_in_place to avoid blocking the Tokio runtime. Uses Box::pin for the FanOut case to handle recursive async.

pub fn send_raw<'a>( &'a mut self, json: &'a str, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'a>>

Write a pre-serialized JSON string directly to this sink.

pub fn into_leaves(self) -> Vec<Sink>

Flatten a (possibly nested) FanOut into its leaf sinks.

The delivery layer runs one worker per leaf, so fan-out is realized by the dispatcher rather than by a FanOut variant on the hot path.

Trait Implementations

impl DeliverySink for Sink

fn deliver<'a>( &'a mut self, result: &'a ProcessResult, ) -> Pin<Box<dyn Future<Output = Result<(), RuntimeError>> + Send + 'a>>

Deliver a single result, returning an error the worker may retry.

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

Short, stable label used for structured logs and per-sink metrics.