Struct NativeArchive 

pub struct NativeArchive<P: CopperListTuple> { /* private fields */ }

One application-typed archive per (session id, sender id). Pass all ordered router events for that sender to accept. The expected schema comes from P’s generated output specs, independently of the remote manifest. CaptureArchive applies the generated selective codec for a live twin. A write failure poisons the writer: do not retry a partially committed event.

Implementations

impl<P: CopperListTuple> NativeArchive<P>

pub fn new( path: &Path, received: &ReceivedManifest, slab_bytes: usize, section_bytes: usize, ) -> Result<Self>

Creates native message, task state, continuity and structured log sections. The section size must fit the largest accepted canonical entry.

pub fn accept( &mut self, event: &SessionEventRef<'_>, ) -> Result<Option<CopperList<P>>>

Validates a typed CopperList once, appends its original canonical bytes, and returns the typed value for an in-process consumer. Keyframes are archived only after the router has verified their recovery point references.

pub fn take_structured_log(&mut self) -> Option<CuLogEntry>

Move the structured entry decoded during the most recent successful accept. Call before accepting another event; publication can reuse this owned value.

pub fn finish(self) -> Result<()>

Records the receiver’s final known boundary and closes native sections. The router must first be finalized through any caller-known sender tail.