class LavinMQ::Replication::Follower

• LavinMQ::Replication::Follower
• Reference
• Object

Defined in:

lavinmq/replication/follower.cr

Constant Summary

Log = ::Log.for(self)

Constructors

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

Instance Method Summary

• #add(path, mfile : MFile | Nil = nil) : Int64
• #append(path, obj) : Int64
• #close(synced_close : Channel(Tuple(Follower, Bool)) | Nil = nil)
• #closed? : Bool
• #delete(path) : Int64
• #full_sync : Nil
• #lag : Int64
• #name : String
• #negotiate!(password) : Nil
• #read_ack(socket = @socket) : Nil
• #read_acks(socket = @socket) : Nil
• #to_json(json : JSON::Builder)

Constructor Detail

Instance Method Detail