Struct MultipathSender 

pub struct MultipathSender { /* private fields */ }

Sends packets across multiple paths according to a SchedulingPolicy.

Implementations

impl MultipathSender

pub fn new(paths: Vec<PathInfo>, policy: SchedulingPolicy) -> Self

Create a new sender with the given paths and scheduling policy.

Panics

Panics if paths is empty.

pub fn select_path_index(&mut self, data_len: usize) -> Option<usize>

Select the best path index for the next packet based on the policy.

Returns None if no active paths are available.

pub fn select_all_paths(&mut self) -> Vec<usize>

For Redundant policy — returns ALL active path indices.

Each path should receive a copy of the packet.

pub fn path(&self, index: usize) -> Option<&PathInfo>

Get an immutable reference to a path by index.

pub fn path_mut(&mut self, index: usize) -> Option<&mut PathInfo>

Get a mutable reference to a path by index.

pub fn paths(&self) -> &[PathInfo]

Returns all paths.

pub fn active_path_count(&self) -> usize

Returns the number of active paths.

pub fn deactivate_path(&mut self, index: usize)

Mark a path as inactive (e.g. interface went down).

pub fn activate_path(&mut self, index: usize)

Mark a path as active again (e.g. interface came back up).

pub fn record_loss(&mut self, index: usize)

Record a packet loss on a specific path.

pub fn update_rtt(&mut self, index: usize, rtt: Duration)

Update RTT estimate for a specific path.

pub fn total_scheduled(&self) -> u64

Total packets scheduled across all paths.

pub fn set_policy(&mut self, policy: SchedulingPolicy)

Change the scheduling policy at runtime.

pub fn policy(&self) -> &SchedulingPolicy

Returns the current scheduling policy.