Struct TapProcess 

pub struct TapProcess { /* private fields */ }

A running tap process and its stdout message channel.

Implementations

impl TapProcess

pub fn spawn( cfg: &SingerSourceConfig, start_state: Option<&Value>, ) -> Result<Self, FaucetError>

Spawn the tap with --config (and optionally --catalog / --state).

start_state is the resume bookmark loaded from the state store (the STATE value blob), materialized to a state.json and passed as --state when present.

pub async fn recv(&mut self, idle_timeout: Option<Duration>) -> Recv

Receive the next stdout line, honoring the optional idle timeout.

pub fn stderr_tail(&self) -> String

The trailing stderr lines (already redacted), newest last.

pub async fn shutdown_and_check(&mut self) -> Result<(), FaucetError>

Gracefully stop the tap (SIGTERM → grace → SIGKILL) and reap it, then return an error if it exited non-zero. Idempotent-ish: safe to call once on the normal EOF path or the idle-timeout path.

pub async fn shutdown(&mut self)

Terminate and reap the tap, ignoring its exit status. Used on the error paths (idle timeout, malformed-fail) where the failure reason is already known and the exit code is irrelevant.