Crate atomr_cluster_tools 

atomr-cluster-tools. src/contrib/cluster/.

Structs

ClusterClient

ClusterClientSettings

Settings for a ClusterClient.

ClusterPubSub

Mediator that augments a local DistributedPubSub with a cross-node topic table + transport. Clusters publish via ClusterPubSub::publish_remote which fans out to all nodes that have advertised the topic; receivers route the payload to local subscribers using the codec registry.

ClusterReceptionist

ClusterSingletonManager

Decides which node hosts the singleton based on oldest up-member — a hook is provided so tests can simulate handover without wiring the full cluster.

ClusterSingletonProxy

Proxy that routes messages to the current singleton, buffering during handover.

DistributedPubSub

Enums

ClusterClientError

MediatorPdu

Wire shape of a cross-node mediator exchange.

SingletonState

Singleton lifecycle state.

Traits

MediatorTransport

Pluggable transport for the cross-node mediator. Sends an outbound MediatorPdu to a peer node, identified by an opaque string node id (typically Address::to_string()). The transport is responsible for the wire round-trip; on the receiver side, the inbound PDU is fed back into the local mediator via ClusterPubSub::apply_pdu.