Struct SpoolEntry 

pub struct SpoolEntry {
    pub input: ObservationInput,
    pub capsule_id: Option<Id>,
    pub validate: Option<bool>,
    pub spooled_at: Option<i64>,
}

A single buffered observation request, one per NDJSON line.

Field names are camelCase to match the wire shapes of the wrapped append_observation arguments, so a spool file doubles as a debuggable / importable record.

Fields

input: ObservationInput

The observation input (its id is always populated by the time it is spooled, so replay is idempotent on id).

capsule_id: Option<Id>

Optional capsule to attach the observation to.

validate: Option<bool>

Optional service-side validation toggle.

spooled_at: Option<i64>

Epoch milliseconds when this entry was written to the spool. Used as the basis for the age retention cap — distinct from input.ts (the observation time, which can be far in the past for historical replays). Legacy entries written before this field existed deserialize to None and are byte-trimmable but never age-trimmed.

Trait Implementations

impl Clone for SpoolEntry

fn clone(&self) -> SpoolEntry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SpoolEntry

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SpoolEntry

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SpoolEntry

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.