Struct RunningDaemon 

pub struct RunningDaemon { /* private fields */ }

A built sync daemon, ready to run. Exposes its live Status so a transport the binary owns can serve it concurrently with the run.

Implementations

impl RunningDaemon

pub fn status(&self) -> Arc<Status>

A handle to the live operational status, for a transport (HTTP, a TUI, …) to read while the daemon runs. Cheap to clone.

pub async fn run(self, shutdown: impl Future<Output = ()> + Send) -> Result<()>

Run until the live stream ends, an error stops the pipeline, or shutdown resolves — typically a signal future the binary owns. A pending batch on shutdown is simply redelivered on the next run (at-least-once), so dropping the run mid-flight is safe.

Trait Implementations

impl Debug for RunningDaemon

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.