struct LavinMQ::Clustering::AppendAction

Defined in:

lavinmq/clustering/actions.cr

Constructors

Instance Method Summary

Instance methods inherited from struct LavinMQ::Clustering::Action

filename : String filename, lag_size : Int64 lag_size, send(socket : IO, log = Log) : Int64 send

Constructor methods inherited from struct LavinMQ::Clustering::Action

new(data_dir : String, filename : String) new

Constructor Detail

def self.new(data_dir : String, filename : String, obj : Bytes | FileRange | UInt32 | Int32) #

[View source]

Instance Method Detail

def lag_size : Int64 #

[View source]
def send(socket, log = Log) : Int64 #

[View source]