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