Module io 

Structs

FileSink

Appends ProcessResult as NDJSON to a file with buffered writes.

StdinSource

Reads events from stdin, one per line.

StdoutSink

Serializes ProcessResult to NDJSON and writes to stdout.

Enums

Sink

Enum dispatch for output adapters.

Traits

EventSource

Contract for event input adapters.

Functions

spawn_source

Spawn an EventSource as a tokio task wired to a shared event channel.