Struct RelayConnection 

pub struct RelayConnection { /* private fields */ }

Relay connection for bidirectional data forwarding

Implementations

impl RelayConnection

pub fn new( session_id: u32, peer_addr: SocketAddr, config: RelayConnectionConfig, event_sender: UnboundedSender<RelayEvent>, action_receiver: UnboundedReceiver<RelayAction>, ) -> Self

Create a new relay connection

pub fn session_id(&self) -> u32

Get session ID

pub fn peer_addr(&self) -> SocketAddr

Get peer address

pub fn is_active(&self) -> bool

Check if connection is active

pub fn send_data(&self, data: Vec<u8>) -> RelayResult<()>

Send data through the relay

pub fn receive_data(&self, data: Vec<u8>) -> RelayResult<()>

Receive data from the relay

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

Get next outgoing data packet

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

Get next incoming data packet

pub fn check_timeout(&self) -> RelayResult<()>

Check if connection has timed out

pub fn should_send_keep_alive(&self) -> bool

Check if keep-alive should be sent

pub fn send_keep_alive(&self) -> RelayResult<()>

Send keep-alive

pub fn terminate(&self, reason: String) -> RelayResult<()>

Terminate the connection

pub fn get_stats(&self) -> ConnectionStats

Get connection statistics

Trait Implementations

impl Debug for RelayConnection

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

Formats the value using the given formatter.