class Fluent::StatusInput::TimerWatcher

def initialize(interval, repeat, &callback)
  @callback = callback
  super(interval, repeat)
end

def on_timer
  @callback.call
rescue
  # TODO log?
  $log.error $!.to_s
  $log.error_backtrace
end