Karma::Wal

ENTRY_OFFSET_CACHE_FILES = 8

FILE_NAME = "karma.wal"

INDEX_EXTENSION = ".idx"

LSN_FILE_NAME = "karma.wal.lsn"

LSN_MUTEX = Mutex.new

SEGMENT_EXTENSION = ".segment"

SEGMENT_INDEX_HEADER = "KARMA_WAL_INDEX_V1"

append(directive : Commands::Directive) : Bool

append(directives : Array(Commands::Directive)) : Bool

bytes(dump_dir = Karma.config.dump_dir) : Int64

current_lsn(dump_dir = Karma.config.dump_dir) : UInt64

entries_after(after_lsn : UInt64, limit : Int32 = 1000, dump_dir = Karma.config.dump_dir) : Array(Entry)

entries_page_after(after_lsn : UInt64, limit : Int32 = 1000, dump_dir = Karma.config.dump_dir, max_bytes : Int32 | Nil = nil) : EntriesPage

lsn_path(dump_dir = Karma.config.dump_dir) : String

path(dump_dir = Karma.config.dump_dir) : String

paths(dump_dir = Karma.config.dump_dir) : Array(String)

persist?(directive : Commands::Directive) : Bool

replay(cluster : Cluster, dump_dir = Karma.config.dump_dir) : Nil

segment_first_lsn(file_path : String) : UInt64 | Nil

segment_index_path(segment_path : String) : String

segment_path(dump_dir : String, first_lsn : UInt64) : String

segment_paths(dump_dir = Karma.config.dump_dir) : Array(String)