Struct overnet_core::Router

pub struct Router { /* private fields */ }

Router maintains global state for one node_id. LinkData is a token identifying a link for layers above Router. Time is a representation of time for the Router, to assist injecting different platforms schemes.

Implementations

impl Router

pub fn new(router_interval: Option<Duration>) -> Result<Arc<Self>, Error>

Create a new router. If router_interval is given, this router will behave like an interior node and tell its neighbors about each other.

pub fn with_node_id( node_id: NodeId, router_interval: Option<Duration> ) -> Result<Arc<Self>, Error>

Make a router with a specific node ID.

pub fn circuit_node(&self) -> &Node

Get the circuit protocol node for this router. This will let us create new connections to other nodes.

pub fn node_id(&self) -> NodeId

Accessor for the node id of this router.

pub fn client_routing(&self) -> AscenddClientRouting

Accessor for whether to route ascendd clients to each other

pub fn set_client_routing(&self, client_routing: AscenddClientRouting)

Setter for whether to route ascendd clients to each other

pub async fn connect_to_service( self: &Arc<Self>, node_id: NodeId, service_name: &str, chan: Channel ) -> Result<(), Error>

Create a new stream to advertised service service on remote node id node.

pub async fn register_service( &self, service_name: String, provider: impl Fn(Channel) -> Result<(), Error> + Send + 'static ) -> Result<(), Error>

Register a service. The callback should connect the given channel to the service in question.

pub async fn new_list_peers_context(&self) -> ListPeersContext

Create a new list_peers context

Trait Implementations

impl Debug for Router

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

Formats the value using the given formatter.