Struct Node

pub struct Node<SE, PA>(/* private fields */);

A participant in the Ankurah network, and primary place where queries are initiated

Implementations

impl<SE, PA> Node<SE, PA>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

pub fn new(engine: Arc<SE>, policy_agent: PA) -> Self

pub fn new_durable(engine: Arc<SE>, policy_agent: PA) -> Self

pub fn weak(&self) -> WeakNode<SE, PA>

Trait Implementations

impl<SE, PA> Clone for Node<SE, PA>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<SE, PA> Deref for Node<SE, PA>

type Target = Arc<NodeInner<SE, PA>>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<SE, PA> Drop for Node<SE, PA>

fn drop(&mut self)

Executes the destructor for this type.

impl<SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static> NodeComms for Node<SE, PA>

fn id(&self) -> NodeId

fn durable(&self) -> bool

fn register_peer(&self, presence: Presence, sender: Box<dyn PeerSender>)

fn deregister_peer(&self, node_id: NodeId)

fn handle_message<'life0, 'async_trait>( &'life0 self, message: NodeMessage, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn cloned(&self) -> Box<dyn NodeComms>

impl<SE, PA> TNodeErased for Node<SE, PA>

where SE: StorageEngine + Send + Sync + 'static, PA: PolicyAgent + Send + Sync + 'static,

fn unsubscribe(&self, handle: &SubscriptionHandle)