class LavinMQ::Clustering::Follower

Defined in:

lavinmq/clustering/follower.cr

Constant Summary

Log = ::Log.for("clustering.follower")

Constructors

Instance Method Summary

Constructor Detail

def self.new(socket : TCPSocket, data_dir : String, file_index : FileIndex) #

[View source]

Instance Method Detail

def action_loop(lz4 = @lz4) #

[View source]
def add(path, mfile : MFile | Nil = nil) : Int64 #

[View source]
def append(path, obj) : Int64 #

[View source]
def close #

[View source]
def delete(path) : Int64 #

[View source]
def full_sync : Nil #

[View source]
def id : Int32 #

[View source]
def lag : Int64 #

[View source]
def negotiate!(password) : Nil #

[View source]
def remote_address : Socket::IPAddress #

[View source]
def to_json(json : JSON::Builder) #

[View source]