Struct SessionOutputSender 

pub struct SessionOutputSender { /* private fields */ }

Cloneable producer for the byte-bounded session output queue.

Implementations

impl SessionOutputSender

pub fn channel() -> (Self, Receiver<SessionOutputEnvelope>)

Create one ordered queue with a separate byte budget for data-bearing events.

pub fn split_channel() -> (Self, Receiver<SessionOutputEnvelope>, Receiver<SessionOutputEnvelope>, Receiver<BulkOutputCommand>)

Create independently bounded control and raw-bulk producer queues.

pub fn with_incarnation(&self, incarnation: Option<ClientIncarnation>) -> Self

Scope future producer events to the client incarnation that opened their session.

pub fn disable_bulk_scheduler(&mut self)

Restore one ordered producer queue after boot selected combined mode.

pub fn drop_bulk_flow( &self, id: u32, ) -> Result<Option<Receiver<()>>, &'static str>

Queue a high-priority purge for one operation without awaiting bulk-port progress.

pub fn drop_bulk_incarnation( &self, incarnation: ClientIncarnation, ) -> Result<Option<Receiver<()>>, &'static str>

Queue a high-priority purge for a disconnected range owner.

pub async fn send(&self, id: u32, output: SessionOutput) -> bool

Queue an event after its retained allocation has acquired aggregate capacity.

pub async fn reserve(&self, max_bytes: usize) -> Option<SessionOutputPermit>

Reserve capacity before reading or encoding up to max_bytes of output.

pub async fn reserve_bulk( &self, max_bytes: usize, ) -> Option<SessionOutputPermit>

Reserve capacity from the raw-bulk budget before allocating a record payload.

pub async fn send_reserved( &self, id: u32, output: SessionOutput, permit: SessionOutputPermit, ) -> bool

Queue output using capacity obtained before the producer created its allocation.

Trait Implementations

impl Clone for SessionOutputSender

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.