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
Sourcecheckpoint_count
Sourcelast_checkpoint_unix
Sourcereset!
Sourcestatus(source : String | Nil = nil)
Source