Skip to main contentModule io
Source - webhook
- Generic, template-driven webhook output sink (roadmap item #54).
- DeliveryConfig
- Per-sink delivery tuning. Public so the CLI can build it from config.
- DeliveryContext
- Per-delivery identity, created once per queued item and reused on every
retry attempt.
- DeliveryFailure
- A result that could not be delivered after exhausting retries.
- Dispatcher
- Drives every sink for the daemon output path.
- FileSink
- Appends ProcessResult as NDJSON to a file with buffered writes.
- IncidentEnvelope
- A pre-serialized incident line plus an optional NATS subject override.
- 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.
- OnFull
- Behavior when a worker’s bounded queue is full.
- Sink
- Enum dispatch for output adapters.
- DeliverySink
- A sink the delivery layer can drive: deliver one result, identify itself.
- EventSource
- Contract for event input adapters.
- spawn_source
- Spawn an EventSource as a tokio task wired to a shared event channel.