class LavinMQ::Replication::Server::Follower

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

Defined in:

lavinmq/replication/server.cr

Constant Summary

Log = ::Log.for(self)

Constructors

• .new(socket : TCPSocket, server : Server)

Instance Method Summary

• #ack : Channel(Nil)
• #add(path, mfile : MFile | Nil = nil)
• #append(path, obj)
• #close
• #delete(path)
• #full_sync : Nil
• #lag : Int64
• #negotiate!(password) : Nil
• #read_acks(socket = @socket) : Nil
• #to_json(json : JSON::Builder)

Constructor Detail

Instance Method Detail