# File lib/fluent/plugin_helper/timer.rb, line 66 def initialize(title, interval, repeat, log, checker, &callback) @title = title @callback = callback @repeat = repeat @log = log @checker = checker super(interval, repeat) end
# File lib/fluent/plugin_helper/timer.rb, line 75 def on_timer @callback.call if @checker.call rescue => e @log.error "Unexpected error raised. Stopping the timer.", title: @title, error: e @log.error_backtrace detach @log.error "Timer detached.", title: @title ensure if attached? detach unless @repeat end end