Struct ConstrainedEngine 

pub struct ConstrainedEngine { /* private fields */ }

The constrained protocol engine

Manages multiple connections and provides a simple API for sending/receiving data.

Implementations

impl ConstrainedEngine

pub fn new(config: EngineConfig) -> Self

Create a new constrained protocol engine

pub fn with_defaults() -> Self

Create with default configuration

pub fn connection_count(&self) -> usize

Number of active connections

pub fn can_accept_connection(&self) -> bool

Check if we can accept more connections

pub fn connect( &mut self, remote_addr: SocketAddr, ) -> Result<(ConnectionId, Vec<u8>), ConstrainedError>

Initiate a connection to a remote address

Returns the connection ID and a SYN packet to transmit.

pub fn process_incoming( &mut self, remote_addr: SocketAddr, data: &[u8], ) -> Result<Vec<(SocketAddr, Vec<u8>)>, ConstrainedError>

Process an incoming packet

Returns any response packets that need to be transmitted.

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

Send data on a connection

pub fn recv(&mut self, connection_id: ConnectionId) -> Option<Vec<u8>>

Receive data from a connection

pub fn close( &mut self, connection_id: ConnectionId, ) -> Result<Vec<(SocketAddr, Vec<u8>)>, ConstrainedError>

Close a connection gracefully

pub fn reset( &mut self, connection_id: ConnectionId, ) -> Result<Vec<(SocketAddr, Vec<u8>)>, ConstrainedError>

Reset a connection immediately

pub fn poll(&mut self) -> Vec<(SocketAddr, Vec<u8>)>

Poll the engine for maintenance tasks

This should be called periodically. Returns packets that need to be transmitted.

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

Get next pending event

pub fn has_connection(&self, connection_id: ConnectionId) -> bool

Check if a connection exists

pub fn connection_for_addr(&self, addr: &SocketAddr) -> Option<ConnectionId>

Get connection by remote address

pub fn active_connections(&self) -> Vec<ConnectionId>

Get list of active connection IDs

pub fn connection_state( &self, connection_id: ConnectionId, ) -> Option<ConnectionState>

Get the state of a specific connection

Trait Implementations

impl Debug for ConstrainedEngine

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

Formats the value using the given formatter.