Struct VirtualSocket 

pub struct VirtualSocket { /* private fields */ }

Virtual socket - unified interface over multiple transport legs

Implementations

impl VirtualSocket

pub fn new( config: VirtualSocketConfig, scheduler: Arc<Scheduler>, fallback: Arc<FallbackStateMachine>, ) -> Self

Create a new virtual socket

pub fn with_defaults() -> Self

Create with default configuration

pub async fn register_leg(&self, leg_type: LegType, leg: Arc<dyn TransportLeg>)

Register a transport leg

pub async fn unregister_leg( &self, leg_type: LegType, ) -> Option<Arc<dyn TransportLeg>>

Unregister a transport leg

pub async fn get_leg(&self, leg_type: LegType) -> Option<Arc<dyn TransportLeg>>

Get a transport leg

pub async fn send(&self, data: Bytes, is_priority: bool) -> Result<()>

Send data through the virtual socket

The scheduler selects the optimal path(s).

pub async fn recv(&self) -> Result<Bytes>

Receive data from the virtual socket

pub async fn try_recv(&self) -> Option<Bytes>

Try to receive without blocking

pub async fn start_recv_loop(&self, leg_type: LegType) -> Result<()>

Start background receive loop for a leg

pub fn current_mode(&self) -> TransportMode

Get current transport mode

pub async fn available_legs(&self) -> Vec<LegType>

Get available leg types

pub fn is_closed(&self) -> bool

Check if socket is closed

pub async fn close(&self) -> Result<()>

Close the virtual socket

pub fn scheduler(&self) -> &Arc<Scheduler>

Get scheduler reference

pub fn fallback(&self) -> &Arc<FallbackStateMachine>

Get fallback state machine reference

pub fn start_probe_loop(self: Arc<Self>)

Start the background probe loop to allow transport healing

Trait Implementations

impl Debug for VirtualSocket

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

Formats the value using the given formatter.