class LavinMQ::Clustering::Client

Defined in:

lavinmq/clustering/client.cr

Constant Summary

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

Constructors

Instance Method Summary

Constructor Detail

def self.new(config : Config, id : Int32, password : String, proxy = true) #

[View source]

Instance Method Detail

def close #

[View source]
def follow(host : String, port : Int32) #

[View source]
def follow(uri : String) #

[View source]
def follow(uri : URI) #

[View source]
def follows?(host : String, port : Int32) : Bool #

[View source]
def follows?(uri : String) : Bool #

[View source]
def follows?(uri : URI) : Bool #

[View source]