class Fluent::StatusInput

Public Class Methods

new() click to toggle source
Calls superclass method Fluent::Input.new
# File lib/fluent/plugin/in_status.rb, line 21
def initialize
  super
end

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method Fluent::Input#configure
# 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
on_timer() click to toggle source
# File lib/fluent/plugin/in_status.rb, line 69
def on_timer
  now = Engine.now
  Status.each {|record|
    router.emit(@tag, now, record)
  }
end
run() click to toggle source
# 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
shutdown() click to toggle source
# File lib/fluent/plugin/in_status.rb, line 56
def shutdown
  @loop.watchers.each {|w| w.detach }
  @loop.stop
  @thread.join
end
start() click to toggle source
# 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