Class: Fluent::FlowCounterSimpleFilter

Inherits:
Filter
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/fluent/plugin/filter_flowcounter_simple.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ FlowCounterSimpleFilter

Returns a new instance of FlowCounterSimpleFilter.



12
13
14
15
 
# File 'lib/fluent/plugin/filter_flowcounter_simple.rb', line 12

def initialize
  super
  @output = Fluent::FlowCounterSimpleOutput.new
end

Instance Attribute Details

#output ⇒ Object (readonly)

Returns the value of attribute output.



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

def output
  @output
end

Instance Method Details

#filter_stream(tag, es) ⇒ Object 



17
18
19
20
 
# File 'lib/fluent/plugin/filter_flowcounter_simple.rb', line 17

def filter_stream(tag, es)
  @output.emit(tag, es, Fluent::NullOutputChain.instance)
  es
end