Struct Connection 

pub struct Connection { /* private fields */ }

Connection information.

Implementations

impl Connection

Implementation of Connection

pub fn new(connection_type: ConnType, channel: Channel) -> Self

Create a new Connection

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

Get the remote address

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

Get the local address

pub fn config_data(&self) -> Option<&ClientConfig>

pub fn connection_type(&self) -> ConnType

Get the connection type

pub fn is_outgoing(&self) -> bool

Return true if this node initiated the connection (outbound dial).

gRPC inbound peers use Channel::Server; outbound dials use Channel::Client with config_data set from ClientConfig.

WebSocket is asymmetric: the server accept path still uses Channel::Client for writes, but leaves config_data unset, so inbound WebSocket is distinguished from outbound WebSocket (which always carries config_data from the dial).

pub fn set_link_id(&mut self, link_id: String)

Set the shared link identifier for this connection.

pub fn link_id(&self) -> Option<String>

Get the shared link identifier for this connection.

pub fn remote_slim_version(&self) -> Option<Version>

Get the SLIM version of the remote peer.

pub fn peer_node_id(&self) -> Option<&str>

Get the remote peer’s node identifier (set during link negotiation).

pub fn is_negotiated(&self) -> bool

Returns true if link negotiation has completed (remote_slim_version is set).

pub fn complete_negotiation_as_server( &mut self, link_id: &str, version: Version, ) -> bool

Complete link negotiation on the server (incoming) path.

Stores link_id and version. Returns false if link_id is empty or negotiation is already complete (replay protection).

pub fn complete_negotiation_as_client( &mut self, link_id: &str, version: Version, ) -> bool

Complete link negotiation on the client (outgoing) path.

Verifies the echoed link_id matches what was set, then stores version. Returns false if there is a mismatch or negotiation is already complete.

pub fn with_negotiation(self, link_id: &str, version: &str) -> Self

Set negotiation state at construction time.

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Connection

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

Formats the value using the given formatter.