module
Karma::Recovery
Defined in:
recovery.crConstant Summary
-
FILE_NAME =
"recovery.json" -
MUTEX =
Mutex.new
Class Method Summary
- .checkpoint(source : String, offset : String | Nil, event_id : String | Nil, dump_dir = Karma.config.dump_dir) : Checkpoint
- .checkpoint_count : Int32
- .last_checkpoint_unix : Int64
- .load!(dump_dir = Karma.config.dump_dir) : Nil
- .path(dump_dir = Karma.config.dump_dir) : String
- .reset! : Nil
- .status(source : String | Nil = nil)
Class Method Detail
def self.checkpoint(source : String, offset : String | Nil, event_id : String | Nil, dump_dir = Karma.config.dump_dir) : Checkpoint
#