Available on crate features
source-rest and source-singer only.Expand description
Tap subprocess runner: spawn, stream stdout as parsed messages over a
bounded channel (backpressure), drain stderr into tracing, and always
reap the child (SIGTERM → grace → SIGKILL on the paths we control;
kill_on_drop is the backstop for an abrupt drop/cancel).
Structs§
- Redactor
- Conservative secret redactor: scrubs the scalar string values found in the tap config out of any echoed text (stderr, command description). We can’t know which values are secret, so every non-trivial string leaf is treated as sensitive.
- TapProcess
- A running tap process and its stdout message channel.
Enums§
- Line
- One item read from the tap’s stdout: a parsed message, or a malformed line
(the caller applies the
MalformedPolicy). - Recv
- Outcome of a single
TapProcess::recvcall.