Karma::Idempotency

SNAPSHOT_FILE_NAME = "karma.idempotency.json"

commit_stream(stream, begin_fingerprint : String, chunk_fingerprints : Hash(UInt64, String)) : CommittedStream

committed_stream?(stream_id : String) : CommittedStream | Nil

dump(dump_dir = Karma.config.dump_dir, last_lsn = snapshot_lsn) : SnapshotMetadata

eligible?(directive) : Bool

execute(directive, use_persisted_timestamp : Bool = false, &)

fetch_chunk(offset : UInt64 = 0_u64, limit : Int32 = Karma::Backup::SNAPSHOT_CHUNK_DEFAULT_BYTES, dump_dir = Karma.config.dump_dir)

fingerprint(directive) : String

info(dump_dir = Karma.config.dump_dir) : SnapshotMetadata | Nil

install_stream(metadata : SnapshotMetadata, dump_dir = Karma.config.dump_dir, &) : String

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

prune(before_unix : Int64, limit : Int32 | Nil = nil)

replace_committed_streams(records : Array(CommittedStream)) : Nil

replace_records(records : Array(Record)) : Nil

restore(dump_dir = Karma.config.dump_dir) : Nil

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

store(record : Record) : Nil