Class: Fluent::Tranquility::Plugin

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

Instance Method Summary collapse

Instance Method Details

#start ⇒ Object 



23
24
25
26
27
28
29
30
 
# File 'lib/fluent/tranquility/plugin.rb', line 23

def start
  super
  @writer = Writer.new.tap do |w|
    w.pusher = PusherFactory.call(url: @url, dataset: @dataset, retries: @retries.to_h)
  end

  @formatter = Formatter.new
end