Fluent::Input
obsolete
# File lib/fluent/plugin/in_stream.rb, line 22 def initialize require 'socket' require 'yajl' super end
def listen end
# File lib/fluent/plugin/in_stream.rb, line 45 def run @loop.run(@blocking_timeout) rescue log.error "unexpected error", :error=>$!.to_s log.error_backtrace end
# File lib/fluent/plugin/in_stream.rb, line 35 def shutdown @loop.watchers.each {|w| w.detach } @loop.stop @lsock.close @thread.join end
# File lib/fluent/plugin/in_stream.rb, line 28 def start @loop = Coolio::Loop.new @lsock = listen @loop.attach(@lsock) @thread = Thread.new(&method(:run)) end
[Validate]
Generated with the Darkfish Rdoc Generator 2.