Contents

require 'fluent/plugin/socket_util'

module Fluent
  class UdpInput < SocketUtil::BaseInput
    Plugin.register_input('udp', self)

    config_set_default :port, 5160
    config_param :body_size_limit, :size, :default => 4096

    def listen(callback)
      log.debug "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
  end
end

Version data entries

12 entries across 12 versions & 1 rubygems

Version	Path
fluentd-0.10.62	lib/fluent/plugin/in_udp.rb
fluentd-0.10.61	lib/fluent/plugin/in_udp.rb
fluentd-0.10.60	lib/fluent/plugin/in_udp.rb
fluentd-0.10.59	lib/fluent/plugin/in_udp.rb
fluentd-0.10.58	lib/fluent/plugin/in_udp.rb
fluentd-0.10.57	lib/fluent/plugin/in_udp.rb
fluentd-0.10.56	lib/fluent/plugin/in_udp.rb
fluentd-0.10.55	lib/fluent/plugin/in_udp.rb
fluentd-0.10.54	lib/fluent/plugin/in_udp.rb
fluentd-0.10.53	lib/fluent/plugin/in_udp.rb
fluentd-0.10.52	lib/fluent/plugin/in_udp.rb
fluentd-0.10.51	lib/fluent/plugin/in_udp.rb