Expand description
Stoa capture worker (transcript drain + PII redaction).
See [ARCHITECTURE.md §7 “Capture pipeline (the hot path)”] for the worker semantics and [ARCHITECTURE.md §10 “Redaction filter”] for the pattern catalogue.
The capture worker:
- Claims one row from
.stoa/queue.dbwith a lease. - Reads the source session
JSONLreferenced by the payload. - Runs the
Redactorline-by-line. - Writes the redacted output to
sessions/<session_id>.jsonl. - Appends an entry to
.stoa/audit.log. - Marks the queue row done.
Structs§
- Drain
Result - Side-effect record returned by
drain_onceon success. - Redactor
- Compiled redactor with a fixed pattern set.
- Worker
Config - Paths the worker needs to do its job.
Enums§
- Error
- Errors emitted by the capture worker.
Functions§
- drain_
once - Drain one queue row from a freshly opened queue. Returns
Noneon an empty queue. - drain_
once_ with - Drain one queue row using a caller-provided
Queue. ReturnsNoneon an empty queue.
Type Aliases§
- Result
- Convenience
Resultalias.