Struct Router 

pub struct Router { /* private fields */ }

Implementations

impl Router

pub fn new(config: RouterConfig) -> Self

pub fn peer_id(&self) -> &str

pub fn known_peers(&self) -> Vec<PeerPresence>

pub fn forget_peer(&self, peer_id: &str)

pub fn stats(&self) -> RouterStats

pub fn wrap_sync( &self, encoding: impl Into<String>, payload: JsonValue, target: RouteTarget, ) -> RouteEnvelope

pub fn wrap_signal( &self, room: impl Into<String>, payload: JsonValue, target: RouteTarget, ) -> RouteEnvelope

pub fn wrap_pull_request( &self, request: PullRequest, target: RouteTarget, ) -> RouteEnvelope

pub fn wrap_pull_response( &self, response: PullResponse, target: RouteTarget, reply_to: impl Into<Option<String>>, ) -> RouteEnvelope

pub fn wrap_watch_request( &self, request: WatchRequest, target: RouteTarget, reply_to: impl Into<Option<String>>, ) -> RouteEnvelope

pub fn wrap_watch_event( &self, event: WatchEvent, target: RouteTarget, reply_to: impl Into<Option<String>>, ) -> RouteEnvelope

pub fn wrap_batch( &self, items: Vec<RouteBatchItem>, target: RouteTarget, reply_to: impl Into<Option<String>>, ) -> RouteEnvelope

pub fn wrap_batch_item( &self, item: RouteBatchItem, target: RouteTarget, reply_to: impl Into<Option<String>>, ) -> RouteEnvelope

pub fn presence( &self, replica_id: impl Into<String>, transport: impl Into<String>, capabilities: Vec<String>, topics: Vec<String>, ) -> RouteEnvelope

pub fn peer_exchange( &self, peers: Vec<PeerRecommendation>, target: RouteTarget, reply_to: impl Into<Option<String>>, ) -> RouteEnvelope

pub fn snapshot_request( &self, root: Option<String>, target: RouteTarget, ) -> RouteEnvelope

pub fn snapshot_response( &self, root: Option<String>, snapshot: DatabaseSnapshot, target: RouteTarget, ) -> RouteEnvelope

pub fn accept(&self, envelope: RouteEnvelope) -> RouteDecision

Trait Implementations

impl Clone for Router

fn clone(&self) -> Router

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Router

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

Formats the value using the given formatter.