module

Karma::Recovery

Constants

FILE_NAME = "recovery.json"
MUTEX = Mutex.new

Class methods

checkpoint(source : String, offset : String | Nil, event_id : String | Nil, dump_dir = Karma.config.dump_dir) : Checkpoint
Source
checkpoint_count
Source
last_checkpoint_unix
Source
load!(dump_dir = Karma.config.dump_dir) : Nil
Source
path(dump_dir = Karma.config.dump_dir) : String
Source
reset!
Source
status(source : String | Nil = nil)
Source

Nested types