Ingestion pipeline
Webhook-triggered async ingestion with Valkey-backed state.
Streaming
SSE semantics, backpressure, cancellation.