Struct Fleet 

pub struct Fleet<M: RawMutex + 'static, const FRAME: usize, const NOTIFY: usize, const LIFECYCLE: usize> { /* private fields */ }

Implementations

impl<M: RawMutex + 'static, const FRAME: usize, const NOTIFY: usize, const LIFECYCLE: usize> Fleet<M, FRAME, NOTIFY, LIFECYCLE>

pub async fn register_member(&self, descriptor: InterfaceDescriptor)

pub async fn deregister_member(&self, id: InterfaceId)

pub fn try_deliver_inbound( &mut self, child: InterfaceId, bytes: &[u8], ) -> Result<(), InboundDeliveryError>

pub async fn deliver_inbound( &mut self, child: InterfaceId, bytes: &[u8], ) -> Result<(), InboundDeliveryError>

Delivers one member frame with end-to-end backpressure.

Supervisors backed by a reliable transport should use this path: when the manifold is still consuming the previous frame, the transport can stop admitting further frames instead of silently turning transient scheduler latency into packet loss.

pub async fn next_outbound(&mut self) -> OutboundFrame<FRAME>

pub async fn outbound_ready(&self)

Waits for a shared-lane commit; drain with try_next_outbound after waking.

pub fn try_next_outbound(&mut self) -> Option<OutboundFrame<FRAME>>