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