Enum StreamContinuityRecord 

pub enum StreamContinuityRecord<B = Vec<u8>> {
    Manifest {
        record: B,
    },
    Gap {
        first_id: u64,
        last_id: u64,
        reason: SourceGapReason,
    },
    RecoveryPoint {
        copperlist_id: u64,
        record: B,
    },
    Finished {
        next_copperlist_id: u64,
    },
}

Stored in UnifiedLogType::StreamContinuity. Ranges are inclusive. Writers use borrowed byte slices; readers choose owned storage when required. Gaps remain missing history even when a later keyframe permits state replay.

Variants

Manifest

Canonical semantic manifest bytes bind identity, receiver requirements and schema.

Fields

record: B

Gap

Fields

first_id: u64

last_id: u64

reason: SourceGapReason

RecoveryPoint

Verified keyframe/manifest references, retained as canonical recovery point bytes.

Fields

copperlist_id: u64

record: B

Finished

Explicit receiver finalization, not a claim about an unobserved sender tail.

Fields

next_copperlist_id: u64

Trait Implementations

impl<'__de, B, __Context> BorrowDecode<'__de, __Context> for StreamContinuityRecord<B>

where B: BorrowDecode<'__de, __Context>,

fn borrow_decode<__D: BorrowDecoder<'__de, Context = __Context>>( decoder: &mut __D, ) -> Result<Self, DecodeError>

Attempt to decode this type with the given BorrowDecode.

impl<B: Clone> Clone for StreamContinuityRecord<B>

fn clone(&self) -> StreamContinuityRecord<B>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<B: Debug> Debug for StreamContinuityRecord<B>

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

Formats the value using the given formatter.

impl<B, __Context> Decode<__Context> for StreamContinuityRecord<B>

where B: Decode<__Context>,

fn decode<__D: Decoder<Context = __Context>>( decoder: &mut __D, ) -> Result<Self, DecodeError>

Attempt to decode this type with the given Decode.

impl<B> Encode for StreamContinuityRecord<B>

where B: Encode,

fn encode<__E: Encoder>(&self, encoder: &mut __E) -> Result<(), EncodeError>

Encode a given type.

impl<B: Eq> Eq for StreamContinuityRecord<B>

impl<B: PartialEq> PartialEq for StreamContinuityRecord<B>

fn eq(&self, other: &StreamContinuityRecord<B>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<B: PartialEq> StructuralPartialEq for StreamContinuityRecord<B>