module Karma::Recovery

Defined in:

recovery.cr

Constant Summary

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

Class Method Summary

Class Method Detail

def self.checkpoint(source : String, offset : String | Nil, event_id : String | Nil, dump_dir = Karma.config.dump_dir) : Checkpoint #

[View source]
def self.checkpoint_count : Int32 #

[View source]
def self.last_checkpoint_unix : Int64 #

[View source]
def self.load!(dump_dir = Karma.config.dump_dir) : Nil #

[View source]
def self.path(dump_dir = Karma.config.dump_dir) : String #

[View source]
def self.reset! : Nil #

[View source]
def self.status(source : String | Nil = nil) #

[View source]