Struct NodeProtocol 

pub struct NodeProtocol { /* private fields */ }

The node protocol for use with Router.

Implementations

impl NodeProtocol

pub fn new() -> Self

Creates a new node protocol state.

pub fn metrics(&self) -> &Arc<NodeMetrics>

Returns a handle to the node metrics.

Trait Implementations

impl Clone for NodeProtocol

fn clone(&self) -> NodeProtocol

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for NodeProtocol

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

Formats the value using the given formatter.

impl Default for NodeProtocol

fn default() -> Self

Returns the “default value” for a type.

impl ProtocolHandler for NodeProtocol

async fn accept(&self, connection: Connection) -> Result<(), AcceptError>

Each incoming connection for our ALPN results in a call to accept.

The returned future runs on a newly spawned Tokio task, so it can run indefinitely as long as the connection remains open.

fn on_accepting( &self, accepting: Accepting, ) -> impl Future<Output = Result<Connection, AcceptError>> + Send

Optional interception point to handle the Accepting state.

fn shutdown(&self) -> impl Future<Output = ()> + Send

Called when the router shuts down.