Struct Deferred 

pub struct Deferred { /* private fields */ }

A deferred segmenter whose records must be persisted before publication.

next returns a cancellation-safe Pending handle. Dropping the handle puts the record back at the front of the ready queue so another storage task can retry it.

Implementations

impl Deferred

pub fn track(&self, name: &str) -> Recorder

Enroll name without letting it influence segmentation.

pub fn pacing_track(&self, name: &str) -> Recorder

Enroll name as a pacing track.

pub fn cut(&self, pts: Timestamp) -> Result<()>

Declare a segment boundary at pts, overriding automatic minimum-duration pacing.

pub fn reserve(&self) -> Reserved

Withhold complete records while a batch of tracks enrolls.

pub fn section(&self) -> Archive

The catalog’s root archive entry describing records built by this segmenter.

pub fn finish(self) -> DeferredDrain

Flush the final open segment and return a handle that can only drain pending records.

pub fn next(&self) -> Option<Pending>

Take the next complete record for storage, if one is ready.

Trait Implementations

impl Clone for Deferred

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.