# File lib/fluent/plugin/in_status.rb, line 21 def initialize super end
# File lib/fluent/plugin/in_status.rb, line 44 def configure(conf) super $log.warn "in_status plugin will be removed v0.14 or later. Use in_monitor_agent instead" end
# File lib/fluent/plugin/in_status.rb, line 69 def on_timer now = Engine.now Status.each {|record| router.emit(@tag, now, record) } end
# File lib/fluent/plugin/in_status.rb, line 62 def run @loop.run rescue log.error "unexpected error", :error=>$!.to_s log.error_backtrace end
# File lib/fluent/plugin/in_status.rb, line 56 def shutdown @loop.watchers.each {|w| w.detach } @loop.stop @thread.join end
# File lib/fluent/plugin/in_status.rb, line 49 def start @loop = Coolio::Loop.new @timer = TimerWatcher.new(@emit_interval, true, log, &method(:on_timer)) @loop.attach(@timer) @thread = Thread.new(&method(:run)) end