Struct Node 

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

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>

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

pub fn deregister_peer(&self, node_id: EntityId)

pub async fn request<'a, C>( &self, node_id: EntityId, cdata: &C, request_body: NodeRequestBody, ) -> Result<NodeResponseBody, RequestError>

where C: Iterable<PA::ContextData>,

pub fn send_update(&self, node_id: EntityId, notification: NodeUpdateBody)

pub async fn handle_message(&self, message: NodeMessage) -> Result<()>

pub async fn commit_remote_transaction( &self, cdata: &PA::ContextData, id: TransactionId, events: Vec<Attested<Event>>, ) -> Result<(), MutationError>

Does all the things necessary to commit a remote transaction

pub fn next_entity_id(&self) -> EntityId

pub fn context(&self, data: PA::ContextData) -> Result<Context, Error>

pub async fn context_async(&self, data: PA::ContextData) -> Context

pub fn get_durable_peer_random(&self) -> Option<EntityId>

Get a random durable peer node ID

pub fn get_durable_peers(&self) -> Vec<EntityId>

Get all durable peer node IDs

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

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

pub async fn fetch_entities_from_local( &self, collection_id: &CollectionId, selection: &Selection, ) -> Result<Vec<Entity>, RetrievalError>

Trait Implementations

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

where PA: PolicyAgent,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

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

where PA: PolicyAgent,

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

The resulting type after dereferencing.

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

Dereferences the value.

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

where PA: PolicyAgent,

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

Formats the value using the given formatter.

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

fn id(&self) -> EntityId

fn durable(&self) -> bool

fn system_root(&self) -> Option<Attested<EntityState>>

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

fn deregister_peer(&self, node_id: EntityId)

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_remote_predicate(&self, query_id: QueryId)

fn update_remote_query( &self, query_id: QueryId, selection: Selection, version: u32, ) -> Result<(), Error>

fn fetch_entities_from_local<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, collection_id: &'life1 CollectionId, selection: &'life2 Selection, ) -> Pin<Box<dyn Future<Output = Result<Vec<Entity>, RetrievalError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn reactor(&self) -> &Reactor<Entity>

fn has_subscription_relay(&self) -> bool