Struct ClusterNode 

pub struct ClusterNode { /* private fields */ }

Running Datum cluster membership node.

Implementations

impl ClusterNode

pub async fn start(config: ClusterConfig) -> ClusterResult<Self>

Start a cluster node with TimeoutDowning using ClusterConfig::downing_timeout.

pub async fn start_with_downing( config: ClusterConfig, downing: Arc<dyn DowningProvider>, ) -> ClusterResult<Self>

Start a cluster node with a custom downing provider.

pub const fn local_addr(&self) -> SocketAddr

Local UDP address bound by the node.

pub const fn advertise_addr(&self) -> SocketAddr

Address advertised to peers.

pub fn node_id(&self) -> &str

Node id.

pub fn state(&self) -> Signal<ClusterState>

Current-state feed.

pub fn events(&self) -> Subscription<MemberEvent>

Lossless membership event feed.

pub fn current_state(&self) -> Arc<ClusterState>

Current immutable membership snapshot.

pub async fn leave(&self) -> ClusterResult<()>

Gracefully leave the cluster.

pub async fn abort(&self) -> ClusterResult<()>

Stop this node without sending a graceful leave. This is useful for crash/failure tests.

pub async fn shutdown(&self) -> ClusterResult<()>

Alias for ClusterNode::abort.

Trait Implementations

impl Drop for ClusterNode

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.