Class: Fluent::Plugin::GraphiteOutput

Inherits:
Output
  • Object
show all
Includes:
Graphite
Defined in:
lib/fluent/plugin/out_graphite.rb

Instance Method Summary collapse

Methods included from Graphite

#format_metrics, #init_client, #init_logger, #initialize, #post

Instance Method Details

#configure(conf) ⇒ Object 



21
22
23
 
# File 'lib/fluent/plugin/out_graphite.rb', line 21

def configure(conf)
  super
end

#process(tag, es) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
 
# File 'lib/fluent/plugin/out_graphite.rb', line 25

def process(tag, es)
  es.each do |time, record|
    emit_tag = tag.dup
    metrics = format_metrics(emit_tag, record)

    # implemented to immediate call post method in this loop, because graphite-api.gem has the buffers.
    post(metrics, time)
  end

end

#start ⇒ Object 



16
17
18
19
 
# File 'lib/fluent/plugin/out_graphite.rb', line 16

def start
  super
  init_client(@log_level, @host, @port)
end