Class: KinesisShard::MemoryStateStore

Inherits:

Object

• Object
• KinesisShard::MemoryStateStore

Defined in:

lib/fluent/plugin/kinesis_shard.rb

Instance Method Summary

• #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.

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

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

Instance Method Details

#load_sequence_number ⇒ Object

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

def load_sequence_number
  @data['last_sequence_number']
end

#update(sequence_number) ⇒ Object

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

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