pub struct Node { /* private fields */ }
Expand description
P2P messages distribution layer group
Implementations§
Source§impl Node
impl Node
pub fn new(adnl: Arc<Node>, key_tag: usize) -> Result<Arc<Self>>
Sourcepub fn query_subscriber(&self) -> Arc<dyn QuerySubscriber>
pub fn query_subscriber(&self) -> Arc<dyn QuerySubscriber>
Returns inner query subscriber
Sourcepub fn metrics(&self) -> impl Iterator<Item = (IdShort, OverlayMetrics)> + '_
pub fn metrics(&self) -> impl Iterator<Item = (IdShort, OverlayMetrics)> + '_
Returns metrics for all overlays
Sourcepub fn add_overlay_subscriber(
&self,
overlay_id: IdShort,
subscriber: Arc<dyn QuerySubscriber>,
) -> bool
pub fn add_overlay_subscriber( &self, overlay_id: IdShort, subscriber: Arc<dyn QuerySubscriber>, ) -> bool
Adds overlay queries subscriber
Sourcepub fn add_public_overlay(
&self,
overlay_id: &IdShort,
options: OverlayOptions,
) -> (Arc<Overlay>, bool)
pub fn add_public_overlay( &self, overlay_id: &IdShort, options: OverlayOptions, ) -> (Arc<Overlay>, bool)
Creates new public overlay
Sourcepub fn add_private_overlay(
&self,
overlay_id: &IdShort,
overlay_key: Arc<Key>,
peers: &[NodeIdShort],
options: OverlayOptions,
) -> (Arc<Overlay>, bool)
pub fn add_private_overlay( &self, overlay_id: &IdShort, overlay_key: Arc<Key>, peers: &[NodeIdShort], options: OverlayOptions, ) -> (Arc<Overlay>, bool)
Creates new private overlay
Auto Trait Implementations§
impl Freeze for Node
impl !RefUnwindSafe for Node
impl Send for Node
impl Sync for Node
impl Unpin for Node
impl !UnwindSafe for Node
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more