Class: Fluent::Plugin::SQLInput::MemoryStateStore

Inherits:

Object

• Object
• Fluent::Plugin::SQLInput::MemoryStateStore

Defined in:

lib/fluent/plugin/in_sql.rb

Instance Method Summary

• #initialize ⇒ MemoryStateStore constructor

  A new instance of MemoryStateStore.

• #last_records ⇒ Object
• #update! ⇒ Object

Constructor Details

#initialize ⇒ MemoryStateStore

Returns a new instance of MemoryStateStore.

# File 'lib/fluent/plugin/in_sql.rb', line 295

def initialize
  @data = {}
end

Instance Method Details

#last_records ⇒ Object

# File 'lib/fluent/plugin/in_sql.rb', line 299

def last_records
  @data['last_records'] ||= {}
end

#update! ⇒ Object

# File 'lib/fluent/plugin/in_sql.rb', line 303

def update!
end