Struct datacake_node::ChitchatNode

pub struct ChitchatNode {
    pub me: Cow<'static, ClusterMember>,
    /* private fields */
}

Fields

me: Cow<'static, ClusterMember>

Implementations

impl ChitchatNode

pub async fn connect(
    me: ClusterMember,
    listen_addr: SocketAddr,
    cluster_id: String,
    seed_nodes: Vec<String>,
    failure_detector_config: FailureDetectorConfig,
    transport: &dyn Transport,
    statistics: ClusterStatistics
) -> Result<Self, NodeError>

pub fn member_change_watcher(
    &self
) -> WatchStream<BTreeMap<NodeId, ClusterMember>>

Return WatchStream for monitoring change of node members.

pub fn members_watcher(&self) -> Receiver<BTreeMap<NodeId, ClusterMember>>

Returns a handle to the members watcher channel.

pub fn statistics(&self) -> ClusterStatistics

Get a handle to the live statistics.

pub async fn shutdown(self)

Leave the cluster.

pub async fn wait_for_members<F>(
    self: &ChitchatNode,
    predicate: F,
    timeout_after: Duration
) -> Result<(), Error>where
    F: FnMut(&BTreeMap<NodeId, ClusterMember>) -> bool,

Convenience method for testing that waits for the predicate to hold true for the cluster’s members.