class Kcl::Workers::RecordCheckpointer
Public Class Methods
new(shard, checkpointer)
click to toggle source
# File lib/kcl/workers/record_checkpointer.rb, line 3 def initialize(shard, checkpointer) @shard = shard @checkpointer = checkpointer end
Public Instance Methods
update_checkpoint(sequence_number)
click to toggle source
# File lib/kcl/workers/record_checkpointer.rb, line 8 def update_checkpoint(sequence_number) # checkpoint the last sequence of a closed shard @shard.checkpoint = sequence_number || Kcl::Checkpoints::Sentinel::SHARD_END @checkpointer.update_checkpoint(@shard) end