pub struct DatacakeNode { /* private fields */ }
Implementations§
Source§impl DatacakeNode
impl DatacakeNode
Sourcepub fn add_rpc_service<Svc>(&self, service: Svc)
pub fn add_rpc_service<Svc>(&self, service: Svc)
Add a RPC service to the existing RPC system.
Sourcepub async fn add_extension<Ext>(
&self,
ext: Ext,
) -> Result<Ext::Output, Ext::Error>where
Ext: ClusterExtension,
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…
Sourcepub fn statistics(&self) -> ClusterStatistics
pub fn statistics(&self) -> ClusterStatistics
Gets the live cluster statistics.
Sourcepub fn network(&self) -> &RpcNetwork
pub fn network(&self) -> &RpcNetwork
Get access to the current RPC network.
Sourcepub fn me(&self) -> &ClusterMember
pub fn me(&self) -> &ClusterMember
Return the cluster member of the node itself.
Sourcepub fn membership_changes(&self) -> WatchStream<MembershipChange>
pub fn membership_changes(&self) -> WatchStream<MembershipChange>
Get a stream of membership changes.
Sourcepub async fn select_nodes(
&self,
consistency: Consistency,
) -> Result<Nodes, ConsistencyError>
pub async fn select_nodes( &self, consistency: Consistency, ) -> Result<Nodes, ConsistencyError>
Selects a set of nodes using a provided consistency level.
Sourcepub async fn wait_for_nodes(
&self,
node_ids: impl AsRef<[NodeId]>,
timeout: Duration,
) -> Result<(), Error>
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.
Sourcepub fn handle(&self) -> DatacakeHandle
pub fn handle(&self) -> DatacakeHandle
Creates a handle to the cluster providing the core functionality of the node.
Auto Trait Implementations§
impl Freeze for DatacakeNode
impl !RefUnwindSafe for DatacakeNode
impl Send for DatacakeNode
impl Sync for DatacakeNode
impl Unpin for DatacakeNode
impl !UnwindSafe for DatacakeNode
Blanket Implementations§
Source§impl<T> ArchivePointee for T
impl<T> ArchivePointee for T
Source§type ArchivedMetadata = ()
type ArchivedMetadata = ()
The archived version of the pointer metadata for this type.
Source§fn pointer_metadata(
_: &<T as ArchivePointee>::ArchivedMetadata,
) -> <T as Pointee>::Metadata
fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata
Converts some archived metadata to the pointer metadata for itself.
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
Source§impl<F, W, T, D> Deserialize<With<T, W>, D> for F
impl<F, W, T, D> Deserialize<With<T, W>, D> for F
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> LayoutRaw for T
impl<T> LayoutRaw for T
Source§fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>
Gets the layout of the type.