class Fluent::StatusInput

def configure(conf)
  super
end

def initialize
  super
end

def on_timer
  now = Engine.now
  Status.each {|record|
    Engine.emit(@tag, now, record)
  }
end

def run
  @loop.run
rescue
  $log.error "unexpected error", :error=>$!.to_s
  $log.error_backtrace
end

def shutdown
  @loop.watchers.each {|w| w.detach }
  @loop.stop
  @thread.join
end

def start
  @loop = Coolio::Loop.new
  @timer = TimerWatcher.new(@emit_interval, true, &method(:on_timer))
  @loop.attach(@timer)
  @thread = Thread.new(&method(:run))
end