Parent

Class/Module Index [+]

Quicksearch

Fluent::SocketUtil::BaseInput

Public Class Methods

new() click to toggle source
# File lib/fluent/plugin/socket_util.rb, line 76
def initialize
  super
  require 'fluent/parser'
end

Public Instance Methods

configure(conf) click to toggle source
# File lib/fluent/plugin/socket_util.rb, line 87
def configure(conf)
  super

  @parser = TextParser.new
  @parser.configure(conf)
end
run() click to toggle source
# File lib/fluent/plugin/socket_util.rb, line 108
def run
  @loop.run
rescue => e
  log.error "unexpected error", :error => e, :error_class => e.class
  log.error_backtrace
end
shutdown() click to toggle source
# File lib/fluent/plugin/socket_util.rb, line 101
def shutdown
  @loop.watchers.each { |w| w.detach }
  @loop.stop
  @handler.close
  @thread.join
end
start() click to toggle source
# File lib/fluent/plugin/socket_util.rb, line 94
def start
  @loop = Coolio::Loop.new
  @handler = listen(method(:on_message))
  @loop.attach(@handler)
  @thread = Thread.new(&method(:run))
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.