Parent

Methods

Class/Module Index [+]

Quicksearch

Fluent::TcpInput

obsolete
ForwardInput is backward compatible with TcpInput

class TcpInput < StreamInput

Plugin.register_input('tcp', self)

config_param :port, :integer, :default => DEFAULT_LISTEN_PORT
config_param :bind, :string, :default => '0.0.0.0'

def configure(conf)
  super
end

def listen
  $log.debug "listening fluent socket on #{@bind}:#{@port}"
  Coolio::TCPServer.new(@bind, @port, Handler, method(:on_message))
end

end

Public Class Methods

new() click to toggle source
# File lib/fluent/plugin/in_stream.rb, line 179
def initialize
  super
  $log.warn "'tcp' input is obsoleted and will be removed soon. Use 'forward' instead."
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.