Struct ConstrainedConnection 

pub struct ConstrainedConnection { /* private fields */ }

A constrained protocol connection

Manages the full lifecycle of a connection including:

• State machine transitions
• Reliable delivery via ARQ
• Packet serialization/deserialization
• Keep-alive management

Implementations

impl ConstrainedConnection

pub fn new_outbound( connection_id: ConnectionId, remote_addr: SocketAddr, ) -> Self

Create a new outbound connection (initiator)

pub fn new_outbound_with_config( connection_id: ConnectionId, remote_addr: SocketAddr, config: ConnectionConfig, ) -> Self

Create a new outbound connection with config

pub fn new_inbound(connection_id: ConnectionId, remote_addr: SocketAddr) -> Self

Create a new inbound connection (responder)

pub fn new_inbound_with_config( connection_id: ConnectionId, remote_addr: SocketAddr, config: ConnectionConfig, ) -> Self

Create a new inbound connection with config

pub fn connection_id(&self) -> ConnectionId

Get the connection ID

pub fn remote_addr(&self) -> SocketAddr

Get the remote address

pub fn state(&self) -> ConnectionState

Get current connection state

pub fn is_established(&self) -> bool

Check if connection is established

pub fn is_closed(&self) -> bool

Check if connection is closed

pub fn can_send(&self) -> bool

Check if we can send data

pub fn initiate(&mut self) -> Result<ConstrainedPacket, ConstrainedError>

Initiate connection (for outbound connections)

Returns a SYN packet to transmit.

pub fn accept( &mut self, syn_seq: SequenceNumber, ) -> Result<ConstrainedPacket, ConstrainedError>

Accept a connection (for inbound connections after receiving SYN)

Returns a SYN-ACK packet to transmit.

pub fn send(&mut self, data: &[u8]) -> Result<(), ConstrainedError>

Send data

Data may be fragmented if larger than MSS.

pub fn recv(&mut self) -> Option<Vec<u8>>

Receive next available data

pub fn close(&mut self) -> Result<ConstrainedPacket, ConstrainedError>

Close the connection gracefully

pub fn reset(&mut self) -> ConstrainedPacket

Reset the connection immediately

pub fn process_packet( &mut self, packet: &ConstrainedPacket, ) -> Result<(), ConstrainedError>

Process an incoming packet

pub fn poll(&mut self) -> Vec<ConstrainedPacket>

Poll the connection for timeout handling and retransmissions

Returns packets that need to be (re)transmitted.

pub fn next_event(&mut self) -> Option<ConnectionEvent>

Get next pending event

pub fn stats(&self) -> ConnectionStats

Get connection statistics

Trait Implementations

impl Debug for ConstrainedConnection

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

Formats the value using the given formatter.