Struct SenderCore 

pub struct SenderCore { /* private fields */ }

A destination’s single packet scheduler and retained recovery state.

now always belongs to the same local RobotClock. The caller owns transport and wakeups; this core neither reads a global clock nor sleeps. Runtime objects are never retained here. Optional feedback can later request the same retained jobs through request_recovery, without bypassing this scheduler’s budget.

Implementations

impl SenderCore

pub fn set_repair_interval(&mut self, every: u16) -> Result<()>

Changes only future repair scheduling; retained packets and budgets are untouched.

pub fn new( config: LogStreamSenderConfig, now: CuTime, reserved_bytes: usize, ) -> Result<Self>

Validate all storage arithmetic before allocating. reserved_bytes covers the driver’s owned-record pool, which shares the destination budget.

pub const fn stats(&self) -> SenderStats

pub fn accept_record(&mut self, record: &[u8], now: CuTime) -> Result<()>

Admit an already encoded record from a bounded worker buffer. No borrow escapes this call. CL packets shed on overflow; retained recovery replaces only a complete matching boundary/keyframe pair.

pub fn request_recovery(&mut self)

Coalesced request for retained bootstrap data. Future advisory feedback uses this same operation; it grants neither extra bandwidth nor retention.

pub fn begin_shutdown(&mut self)

Disable periodic work. The driver enforces the finite shutdown deadline.

pub fn discard_pending(&mut self)

Account for work abandoned at the driver’s finite shutdown deadline.

pub fn is_idle(&self) -> bool

pub fn poll<T: CuStreamTx>( &mut self, now: CuTime, transport: &mut T, ) -> Result<Option<CuTime>>

Send a bounded amount of eligible work and return the next local deadline. Carrier WouldBlock consumes the attempt’s budget and drops the packet.