Struct DatacakeNode

pub struct DatacakeNode { /* private fields */ }

Implementations

impl DatacakeNode

pub async fn shutdown(self)

Shuts down the cluster and cleans up any connections.

pub fn add_rpc_service<Svc>(&self, service: Svc)

where Svc: RpcService + Send + Sync + 'static,

Add a RPC service to the existing RPC system.

pub async fn add_extension<Ext>( &self, ext: Ext, ) -> Result<Ext::Output, Ext::Error>

where Ext: ClusterExtension,

Adds a new cluster extension to the existing node.

Cluster extensions can be used to extend the cluster to provide additional functionality like storage, messaging, etc…

pub fn statistics(&self) -> ClusterStatistics

Gets the live cluster statistics.

pub fn clock(&self) -> &Clock

Get access to the cluster clock.

pub fn network(&self) -> &RpcNetwork

Get access to the current RPC network.

pub fn me(&self) -> &ClusterMember

Return the cluster member of the node itself.

pub fn membership_changes(&self) -> WatchStream<MembershipChange>

Get a stream of membership changes.

pub async fn select_nodes( &self, consistency: Consistency, ) -> Result<Nodes, ConsistencyError>

Selects a set of nodes using a provided consistency level.

pub async fn wait_for_nodes( &self, node_ids: impl AsRef<[NodeId]>, timeout: Duration, ) -> Result<(), Error>

Waits for the given node IDs to join the cluster or timeout to elapse.

pub fn handle(&self) -> DatacakeHandle

Creates a handle to the cluster providing the core functionality of the node.