class KinesisShard::MemoryStateStore

Public Class Methods

new() click to toggle source
# File lib/fluent/plugin/kinesis_shard.rb, line 139
def initialize
  @data = {'last_sequence_number' => ''}
end

Public Instance Methods

load_sequence_number() click to toggle source
# File lib/fluent/plugin/kinesis_shard.rb, line 143
def load_sequence_number
  @data['last_sequence_number']
end
update(sequence_number) click to toggle source
# File lib/fluent/plugin/kinesis_shard.rb, line 147
def update(sequence_number)
  @data['last_sequence_number'] = sequence_number
end