Struct SpooledClient 

pub struct SpooledClient { /* private fields */ }

A durable-emit wrapper around a crate::Client.

Holds the client, the spool path, and an in-process Mutex that serializes every spool-file operation (single-producer-per-spool-file).

Implementations

impl SpooledClient

pub fn new(client: Client, spool_path: PathBuf) -> Self

Build a durable-emit client over client, buffering to spool_path.

pub fn with_config(client: Client, config: SpoolConfig) -> Self

Build from a SpoolConfig.

pub fn client(&self) -> &Client

Borrow the underlying client for reads / non-spooled ops (retrieve, health, pin, capsules, …). Only append_observation is durability-wrapped.

pub async fn append_observation( &self, input: ObservationInput, capsule_id: Option<Id>, validate: Option<bool>, ) -> Result<AppendOutcome, SpoolError>

Append an observation durably.

Assigns a stable v4 id when input.id is None (so a spooled entry and any replay share one id — see the crate-level Delivery semantics). Then:

1. If the spool already has buffered entries, opportunistically flush them first so the daemon observes them in append order ahead of this new one.
2. Try the daemon. On success → AppendOutcome::Delivered.
3. On a connectivity failure (Unavailable / Http) → buffer to the spool and return AppendOutcome::Spooled (never an error).
4. On any other client error → propagate as SpoolError::Client; the observation is not spooled.

pub async fn flush(&self) -> Result<FlushReport, SpoolError>

Drain the spool into the daemon, in order.

Replays each buffered entry via the client. Stops at the first connectivity failure (Unavailable / Http), keeping that entry and the remainder. A non-connectivity client error also stops the drain and is propagated, but the un-replayed remainder (including the rejected entry) is preserved — data is never silently dropped.

The spool file is rewritten with exactly the un-replayed remainder via a temp-file-then-rename, so a crash mid-flush cannot corrupt the spool.

pub fn pending_count(&self) -> Result<usize, SpoolError>

Count of pending (un-replayed) spool entries.

Trait Implementations

impl Debug for SpooledClient

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

Formats the value using the given formatter.