Class: Fluent::TcpInput

Inherits:

SocketUtil::BaseInput

• Object
• Input
• SocketUtil::BaseInput
• Fluent::TcpInput

Defined in:

lib/fluent/plugin/in_tcp.rb

Constant Summary

Constants included from Configurable

Configurable::CONFIG_TYPE_REGISTRY

Instance Attribute Summary

Attributes inherited from Input

#router

Attributes included from PluginLoggerMixin

#log

Instance Method Summary

• #listen(callback) ⇒ Object

Methods inherited from SocketUtil::BaseInput

#configure, #initialize, #run, #shutdown, #start

Methods inherited from Input

#configure, #initialize, #shutdown, #start

Methods included from PluginLoggerMixin

#configure, included, #initialize

Methods included from PluginId

#configure, #plugin_id

Methods included from Configurable

#config, #configure, included, #initialize, lookup_type, register_type

Constructor Details

This class inherits a constructor from Fluent::SocketUtil::BaseInput

Instance Method Details

#listen(callback) ⇒ Object

# File 'lib/fluent/plugin/in_tcp.rb', line 29

def listen(callback)
  log.info "listening tcp socket on #{@bind}:#{@port}"
  Coolio::TCPServer.new(@bind, @port, SocketUtil::TcpHandler, log, @delimiter, callback)
end