Class: KinesisShard::MemoryStateStore
- Inherits:
-
Object
- Object
- KinesisShard::MemoryStateStore
- Defined in:
- lib/fluent/plugin/kinesis_shard.rb
Instance Method Summary collapse
-
#initialize ⇒ MemoryStateStore
constructor
A new instance of MemoryStateStore.
- #load_sequence_number ⇒ Object
- #update(sequence_number) ⇒ Object
Constructor Details
#initialize ⇒ MemoryStateStore
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_number ⇒ Object
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 |