atomr_cluster/
lib.rs

1//! atomr-cluster. akka.net: `src/core/Akka.Cluster/`.
2//!
3//! Contains membership, gossip, reachability, heartbeat, and the
4//! split-brain resolver strategies.
5
6mod cluster_daemon;
7mod events;
8mod gossip;
9mod gossip_pdu;
10mod heartbeat;
11mod heartbeat_sender;
12mod leader;
13mod member;
14mod membership;
15mod multi_dc;
16mod reachability;
17mod remote_adapter;
18mod sbr;
19mod sbr_runtime;
20mod vector_clock;
21
22pub use cluster_daemon::{
23    spawn_daemon, spawn_daemon_with_sbr, ClusterDaemonHandle, DaemonCmd, DaemonConfig, DaemonSnapshot,
24    GossipTransport, NoSbr,
25};
26pub use events::{ClusterEvent, ClusterEventBus, SubscriptionHandle};
27pub use gossip::{Gossip, GossipOverview};
28pub use gossip_pdu::{decide as gossip_decide, pick_gossip_target, GossipDecision, GossipPdu};
29pub use heartbeat::HeartbeatState;
30pub use heartbeat_sender::{HeartbeatSender, PeerHeartbeat};
31pub use leader::{elect_leader, is_converged, next_status};
32pub use member::{Member, MemberStatus};
33pub use membership::MembershipState;
34pub use multi_dc::{
35    heartbeat_interval_for, member_dc, partition_by_dc, same_dc, CrossDcSettings, DC_ROLE_PREFIX, DEFAULT_DC,
36};
37pub use reachability::{Reachability, ReachabilityStatus};
38pub use remote_adapter::ClusterRemoteAdapter;
39pub use sbr::{
40    DowningDecision, DowningStrategy, KeepMajorityStrategy, KeepOldestStrategy, KeepReferee,
41    LeaseMajorityStrategy, SplitBrainResolver, StaticQuorumStrategy,
42};
43pub use sbr_runtime::{SbrAction, SbrRuntime};
44pub use vector_clock::{VectorClock, VectorRelation};
atomr_cluster/lib.rs

atomr_cluster/
lib.rs
