Class: Fluent::Plugin::FlowCounterSimpleFilter

Inherits:

Filter

• Object
• Filter
• Fluent::Plugin::FlowCounterSimpleFilter

Includes:

FlowcounterSimple

Defined in:

lib/fluent/plugin/filter_flowcounter_simple.rb

Instance Attribute Summary

Attributes included from FlowcounterSimple

#last_checked

Instance Method Summary

• #filter_stream(tag, es) ⇒ Object

Methods included from FlowcounterSimple

#configure, #countup, #flush_emit, included, #process_count, #shutdown, #start, #watch

Instance Method Details

#filter_stream(tag, es) ⇒ Object

# File 'lib/fluent/plugin/filter_flowcounter_simple.rb', line 10

def filter_stream(tag, es)
  process_count(tag, es)
  es
end