Class: Fluent::DashingOutput
- Inherits:
-
Output
- Object
- Output
- Fluent::DashingOutput
- Defined in:
- lib/fluent/plugin/out_dashing.rb
Instance Method Summary collapse
- #configure(conf) ⇒ Object
- #emit(tag, es, chain) ⇒ Object
-
#initialize ⇒ DashingOutput
constructor
A new instance of DashingOutput.
- #shutdown ⇒ Object
- #start ⇒ Object
Constructor Details
#initialize ⇒ DashingOutput
Returns a new instance of DashingOutput.
7 8 9 |
# File 'lib/fluent/plugin/out_dashing.rb', line 7 def initialize super end |
Instance Method Details
#configure(conf) ⇒ Object
16 17 18 19 |
# File 'lib/fluent/plugin/out_dashing.rb', line 16 def configure(conf) super end |
#emit(tag, es, chain) ⇒ Object
31 32 33 34 35 36 37 38 39 40 41 42 |
# File 'lib/fluent/plugin/out_dashing.rb', line 31 def emit(tag, es, chain) es.each {|time,record| next unless value = record[@name_key] body = {} body[:auth_token] = @auth_token body[@event_json_data_key] = value.to_s HTTParty.post(@dashing_url, :body => body.to_json) } chain.next end |
#shutdown ⇒ Object
26 27 28 29 |
# File 'lib/fluent/plugin/out_dashing.rb', line 26 def shutdown super end |
#start ⇒ Object
21 22 23 24 |
# File 'lib/fluent/plugin/out_dashing.rb', line 21 def start super end |