class

LavinMQ::Clustering::Controller

Inherits Reference < Object

Constants

Log = LavinMQ::Log.for("clustering.controller")

Constructors

new(config : Config, etcd : Etcd, coordinator : EtcdCoordinator, metrics_server : HTTP::MetricsServer | Nil = nil)

The metrics server, if any, is pointed at each follower client, so it keeps serving on the same socket across leader changes

Source
new(config : Config)
Source

Instance methods

run
Source
stop
Source
wait_to_be_insync(lease)
Source

Nested types