Class: KinesisShard::MemoryStateStore

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/plugin/kinesis_shard.rb

Instance Method Summary collapse

Constructor Details

#initializeMemoryStateStore

Returns a new instance of MemoryStateStore.



139
140
141
# File 'lib/fluent/plugin/kinesis_shard.rb', line 139

def initialize
  @data = {'last_sequence_number' => ''}
end

Instance Method Details

#load_sequence_numberObject



143
144
145
# File 'lib/fluent/plugin/kinesis_shard.rb', line 143

def load_sequence_number
  @data['last_sequence_number']
end

#update(sequence_number) ⇒ Object



147
148
149
# File 'lib/fluent/plugin/kinesis_shard.rb', line 147

def update(sequence_number)
  @data['last_sequence_number'] = sequence_number
end