Cluster manager - orchestrates membership, gossip, and state synchronization.
This is the internal orchestration layer. Use lb.cluster namespace for the public API.
Cluster manager - orchestrates membership, gossip, and state synchronization. This is the internal orchestration layer. Use lb.cluster namespace for the public API.
(broadcast-state! state-type key value)Broadcast a state change to the cluster.
Broadcast a state change to the cluster.
(broadcast-states! states)Broadcast multiple state changes to the cluster.
Broadcast multiple state changes to the cluster.
(cluster-size)Get number of alive nodes.
Get number of alive nodes.
Default cluster configuration.
Default cluster configuration.
(get-alive-nodes)Get set of alive node IDs.
Get set of alive node IDs.
(get-config)Get current cluster configuration.
Get current cluster configuration.
(merge-config user-config)Merge user config with defaults.
Merge user config with defaults.
(on-node-failure! node-id)Handle a node failure. Called by membership when node is confirmed dead.
Handle a node failure. Called by membership when node is confirmed dead.
(register-provider! provider)Register a state provider for synchronization.
Register a state provider for synchronization.
(running?)Check if cluster manager is running.
Check if cluster manager is running.
(subscribe! callback)Subscribe to cluster events. Returns unsubscribe function.
Subscribe to cluster events. Returns unsubscribe function.
(unregister-provider! type)Unregister a state provider.
Unregister a state provider.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |