Struct Slot 

pub struct Slot {

    pub stream: StreamKey,
    pub epoch: u16,
    pub message_id: u8,
    pub count: u8,
    pub present: u16,
    pub unavailable: u16,
    pub repair_exhausted: u16,
    pub frag_len: [u8; 10],
    pub meta: FirstMeta,
    pub have_meta: bool,
    pub announced: bool,
    pub late: bool,
    pub notified: bool,
    pub handle: MessageHandle,
    pub created_ms: u64,
    pub deadline_ms: u64,
    pub repair_at_ms: u64,
    pub last_fragment_ms: u64,
    /* private fields */
}

One in-progress reassembly.

Fields

stream: StreamKey

epoch: u16

message_id: u8

count: u8

present: u16

Bitmap of fragments whose bytes are stored.

unavailable: u16

Bitmap of fragments the sender reported unavailable.

repair_exhausted: u16

Missing fragments whose automatic repair budget was exhausted. This is separate from unavailable: the body remains pending until the reassembly TTL, but the scheduler must not reset and retry forever.

frag_len: [u8; 10]

meta: FirstMeta

have_meta: bool

announced: bool

An Insert mutation has been emitted for this slot’s handle.

late: bool

This reassembly reused a gap placeholder handle, so its announcing Insert should be flagged “received late”.

notified: bool

A notify-eligible mutation (completion or notify deadline) has already been emitted for this reassembly, so it must not fire again.

handle: MessageHandle

created_ms: u64

deadline_ms: u64

repair_at_ms: u64

Next time repair scheduling may consider this slot.

last_fragment_ms: u64

When the newest fragment was stored; arrivals defer repair from here.

Implementations

impl Slot

pub fn is_complete(&self) -> bool

pub fn is_settled(&self) -> bool

Every fragment is either present or reported unavailable, so no further repair can improve this slot.

pub fn missing(&self) -> impl Iterator<Item = u8> + '_

pub fn repairable_missing(&self) -> impl Iterator<Item = u8> + '_

Trait Implementations

impl Clone for Slot

fn clone(&self) -> Slot

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Slot

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

Formats the value using the given formatter.