Skip to main contentModule io
Source - FileSink
- Appends ProcessResult as NDJSON to a file with buffered writes.
- RawEvent
- An event payload bundled with its acknowledgment token.
- StdinSource
- Reads events from stdin, one per line.
- StdoutSink
- Serializes ProcessResult to NDJSON and writes to stdout.
- AckToken
- Opaque acknowledgment handle returned alongside each event.
- Sink
- Enum dispatch for output adapters.
- EventSource
- Contract for event input adapters.
- spawn_source
- Spawn an EventSource as a tokio task wired to a shared event channel.