Struct datacake_node::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<Vec<SocketAddr>, 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.