Class: Fluent::ForwardOutput::HeartbeatRequestTimer

Inherits:
Coolio::TimerWatcher
  • Object
show all
Defined in:
lib/fluent/plugin/out_forward.rb

Instance Method Summary collapse

Constructor Details

#initialize(interval, callback) ⇒ HeartbeatRequestTimer

Returns a new instance of HeartbeatRequestTimer.



382
383
384
385
 
# File 'lib/fluent/plugin/out_forward.rb', line 382

def initialize(interval, callback)
  super(interval, true)
  @callback = callback
end

Instance Method Details

#on_timer ⇒ Object 



387
388
389
390
391
 
# File 'lib/fluent/plugin/out_forward.rb', line 387

def on_timer
  @callback.call
rescue
  # TODO log?
end