class

LavinMQ::Clustering::Checksums

Inherits Reference < Object

Constants

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

Constructors

new(data_dir : String)

Source

Instance methods

[]?(path) : Entry | Nil

Hash and size are handed out together; the caller decides whether the recorded coverage fits its use.

Source

append(path : String, hash : Bytes, size : Int64) : Nil

Set in memory AND persist immediately by appending one line, so hashing progress survives a crash mid-sync (see Client#sync_files). No fsync: the page cache survives a process crash and the cache is only an optimization (a stale entry just triggers a re-fetch, never data loss).

clear

delete(path)

restore

set(path : String, hash : Bytes, size : Int64) : Nil

Source

size

Source

store