Parent

Class/Module Index [+]

Quicksearch

Fluent::StreamInput

obsolete

Public Class Methods

new() click to toggle source
# File lib/fluent/plugin/in_stream.rb, line 22
def initialize
  require 'socket'
  require 'yajl'
  super
end

Public Instance Methods

run() click to toggle source

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
shutdown() click to toggle source
# File lib/fluent/plugin/in_stream.rb, line 35
def shutdown
  @loop.watchers.each {|w| w.detach }
  @loop.stop
  @lsock.close
  @thread.join
end
start() click to toggle source
# 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.