Karma::Replication

LSN_FILE_NAME = "karma.replication.lsn"

LSN_MUTEX = Mutex.new

METRICS_MUTEX = Mutex.new

apply(entries : Array(Karma::Wal::Entry), cluster : Cluster, dump_dir = Karma.config.dump_dir) : UInt64

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

checkpoint(lsn : UInt64, dump_dir = Karma.config.dump_dir) : UInt64

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

record_bootstrap_error(error : String) : Nil

record_poll_error(error : String) : Nil

record_source_lsn(lsn : UInt64) : Nil

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

status(master_lsn : UInt64 | Nil = nil, dump_dir = Karma.config.dump_dir)