module

LavinMQ::Clustering

Constants

FSYNC_PREFIX = '$'

Start = Bytes['R'.ord, 'E'.ord, 'P'.ord, 'L'.ord, 'I'.ord, 1, 0, 0]

StartV2 = Bytes['R'.ord, 'E'.ord, 'P'.ord, 'L'.ord, 'I'.ord, 2, 0, 0]

Version 2 followers don't sync to disk before every ack; they fsync the files named by fsync request records (a $ prefixed path and a zero length), and syncfs on a bare $.

Nested types

LavinMQ::Clustering::AuthenticationError
LavinMQ::Clustering::Checksums
LavinMQ::Clustering::Client
LavinMQ::Clustering::Controller
LavinMQ::Clustering::Coordinator
LavinMQ::Clustering::Error
LavinMQ::Clustering::EtcdCoordinator
LavinMQ::Clustering::FileIndex
LavinMQ::Clustering::Follower
LavinMQ::Clustering::InvalidStartHeaderError
LavinMQ::Clustering::Proxy
LavinMQ::Clustering::Replicator
LavinMQ::Clustering::Server