class LavinMQ::Clustering::Controller

Defined in:

lavinmq/clustering/controller.cr

Constant Summary

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

Constructors

Instance Method Summary

Constructor Detail

def self.new(config : Config, etcd : Etcd) #

[View source]
def self.new(config : Config) #

[View source]

Instance Method Detail

def id : Int32 #

[View source]
def run(&) #

This method is called by the Launcher#run. The block will be yielded when the controller's prerequisites for a leader to start are met, i.e when the current node has been elected leader. The method is blocking.


[View source]
def stop #

[View source]
def wait_to_be_insync #

[View source]