module Karma::Replication

Defined in:

replication.cr
replication/poller.cr
replication/snapshot_client.cr

Constant Summary

LSN_FILE_NAME = "karma.replication.lsn"

LSN_MUTEX = Mutex.new

METRICS_MUTEX = Mutex.new

Class Method Summary

• .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_attempt : Nil
• .record_bootstrap_error(error : String) : Nil
• .record_bootstrap_success : Nil
• .record_poll_attempt : Nil
• .record_poll_error(error : String) : Nil
• .record_poll_success : Nil
• .record_source_lsn(lsn : UInt64) : Nil
• .replayed_lsn(dump_dir = Karma.config.dump_dir) : UInt64
• .reset! : Nil
• .status(master_lsn : UInt64 | Nil = nil, dump_dir = Karma.config.dump_dir)

Class Method Detail