module Karma::Wal

Defined in:

wal.cr
wal/entry.cr
wal/lsn.cr
wal/replay.cr
wal/serializer.cr
wal/store.cr

Constant Summary

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"

Class Method Summary

• .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
• .enabled? : Bool
• .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
• .fsync? : Bool
• .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
• .reset! : 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)
• .truncate : Bool

Class Method Detail