Class: Fluent::UdpInput

Inherits:

SocketUtil::BaseInput

• Object
• Input
• SocketUtil::BaseInput
• Fluent::UdpInput

Defined in:

lib/fluent/plugin/in_udp.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_udp.rb', line 26

def listen(callback)
  log.info "listening udp socket on #{@bind}:#{@port}"
  @usock = SocketUtil.create_udp_socket(@bind)
  @usock.bind(@bind, @port)
  SocketUtil::UdpHandler.new(@usock, log, @body_size_limit, callback)
end