Struct Uplink 

pub struct Uplink { /* private fields */ }

An individual network uplink.

Implementations

impl Uplink

pub fn new(config: UplinkConfig, numeric_id: u16) -> Self

Create a new uplink.

pub fn id(&self) -> &UplinkId

Get the uplink ID.

pub fn numeric_id(&self) -> u16

Get the numeric ID (for packet headers).

pub fn config(&self) -> &UplinkConfig

Get the configuration.

pub fn state(&self) -> UplinkState

Get current state.

pub fn health(&self) -> UplinkHealth

Get health status.

pub fn is_usable(&self) -> bool

Check if uplink is usable.

pub fn priority_score(&self) -> u32

Get the priority score.

pub fn rtt(&self) -> Duration

Get smoothed RTT.

pub fn bandwidth(&self) -> Bandwidth

Get current bandwidth estimate.

pub fn loss_ratio(&self) -> f64

Get packet loss ratio.

pub fn stats(&self) -> TrafficStats

Get traffic statistics.

pub fn cwnd(&self) -> u32

Get congestion window.

pub fn in_flight(&self) -> u32

Get in-flight packet count.

pub fn can_send(&self) -> bool

Check if congestion window allows sending.

pub fn set_transport(&self, transport: Arc<dyn Transport>)

Set the transport.

pub fn get_transport(&self) -> Option<Arc<dyn Transport>>

Get the transport (cloned Arc).

pub fn set_noise_session(&self, session: NoiseSession)

Set the noise session.

pub async fn send_raw(&self, data: &[u8]) -> Result<usize>

Send raw data through the transport (no encryption).

pub async fn send_encrypted(&self, data: &[u8]) -> Result<usize>

Send encrypted data through the transport. Returns the number of bytes sent (original data size).

pub async fn recv(&self, buf: &mut [u8]) -> Result<usize>

Receive data from transport.

pub async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, SocketAddr)>

Receive data from transport with source address.

pub fn decrypt(&self, ciphertext: &[u8]) -> Result<Vec<u8>>

Decrypt received data.

pub fn is_noise_ready(&self) -> bool

Check if the noise session is ready for transport.

pub fn encrypt(&self, data: &[u8]) -> Result<Vec<u8>>

Encrypt data (get ciphertext without sending).

pub fn write_handshake(&self, payload: &[u8]) -> Result<Vec<u8>>

Write handshake message.

pub fn read_handshake(&self, message: &[u8]) -> Result<Vec<u8>>

Read handshake message.

pub fn set_connection_state(&self, state: ConnectionState)

Update connection state.

pub fn record_send(&self, bytes: usize)

Record a successful send.

pub fn record_recv(&self, bytes: usize)

Record a successful receive.

pub fn record_rtt(&self, rtt: Duration)

Record an RTT measurement.

pub fn record_loss(&self)

Record a packet loss.

pub fn record_failure(&self, error: &str)

Record a failure.

pub fn record_success(&self)

Record a successful operation (resets failure counter).

pub fn periodic_update(&self)

Periodic update (call from timer).

pub fn quality_metrics(&self) -> QualityMetrics

Get quality metrics.

pub fn connection_params(&self) -> ConnectionParams

Get comprehensive connection parameters for throughput optimization. This provides all metrics needed to make intelligent routing decisions.

pub fn send_bandwidth(&self) -> Bandwidth

Get send bandwidth.

pub fn recv_bandwidth(&self) -> Bandwidth

Get receive bandwidth.

pub fn rtt_variance(&self) -> Duration

Get RTT variance (jitter).

pub fn is_natted(&self) -> bool

Check if this uplink is behind NAT.

pub fn nat_type(&self) -> NatType

Get the NAT type detected on this uplink.

pub fn external_addr(&self) -> Option<SocketAddr>

Get the external address (after NAT translation).

pub fn nat_detection_state(&self) -> NatDetectionState

Get NAT detection state for advanced operations.

pub fn update_nat_state<F, R>(&self, f: F) -> R

where F: FnOnce(&mut UplinkNatState) -> R,

Update NAT state with access to mutable reference.

pub fn reset_nat_state(&self)

Reset NAT detection state.

Trait Implementations

impl Debug for Uplink

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

Formats the value using the given formatter.