class LavinMQ::Clustering::Follower

• LavinMQ::Clustering::Follower
• Reference
• Object

Defined in:

lavinmq/clustering/follower.cr

Constant Summary

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

Constructors

• .new(socket : TCPSocket, data_dir : String, file_index : FileIndex)

Instance Method Summary

• #action_loop(lz4 = @lz4)
• #add(path, mfile : MFile | Nil = nil) : Int64
• #append(path, obj) : Int64
• #close(timeout : Time::Span = 30.seconds)
• #delete(path) : Int64
• #full_sync : Nil
• #id : Int32
• #lag_in_bytes : Int64
• #negotiate!(password) : Nil
• #remote_address : Socket::IPAddress
• #to_json(json : JSON::Builder)

Constructor Detail

Instance Method Detail