# File lib/fluent/plugin/in_http.rb, line 40 def configure(conf) super m = if @format == 'default' method(:parse_params_default) else parser = TextParser.new parser.configure(conf) @parser = parser method(:parse_params_with_parser) end (class << self; self; end).module_eval do define_method(:parse_params, m) end end
# File lib/fluent/plugin/in_http.rb, line 113 def on_request(path_info, params) begin path = path_info[1..-1] # remove / tag = path.split('/').join('.') record_time, record = parse_params(params) # Skip nil record if record.nil? return ["200 OK", {'Content-type'=>'text/plain'}, ""] end if @add_http_headers params.each_pair { |k,v| if k.start_with?("HTTP_") record[k] = v end } end time = if param_time = params['time'] param_time = param_time.to_i param_time.zero? ? Engine.now : param_time else record_time.nil? ? Engine.now : record_time end rescue return ["400 Bad Request", {'Content-type'=>'text/plain'}, "400 Bad Request\n#{$!}\n"] end # TODO server error begin # Support batched requests if record.is_a?(Array) mes = MultiEventStream.new record.each do |single_record| single_time = single_record.delete("time") || time mes.add(single_time, single_record) end Engine.emit_stream(tag, mes) else Engine.emit(tag, time, record) end rescue return ["500 Internal Server Error", {'Content-type'=>'text/plain'}, "500 Internal Server Error\n#{$!}\n"] end return ["200 OK", {'Content-type'=>'text/plain'}, ""] end
# File lib/fluent/plugin/in_http.rb, line 106 def run @loop.run rescue log.error "unexpected error", :error=>$!.to_s log.error_backtrace end
# File lib/fluent/plugin/in_http.rb, line 99 def shutdown @loop.watchers.each {|w| w.detach } @loop.stop @lsock.close @thread.join end
# File lib/fluent/plugin/in_http.rb, line 80 def start log.debug "listening http on #{@bind}:#{@port}" lsock = TCPServer.new(@bind, @port) detach_multi_process do super @km = KeepaliveManager.new(@keepalive_timeout) #@lsock = Coolio::TCPServer.new(@bind, @port, Handler, @km, method(:on_request), @body_size_limit) @lsock = Coolio::TCPServer.new(lsock, nil, Handler, @km, method(:on_request), @body_size_limit, @format, log) @lsock.listen(@backlog) unless @backlog.nil? @loop = Coolio::Loop.new @loop.attach(@km) @loop.attach(@lsock) @thread = Thread.new(&method(:run)) end end
Generated with the Darkfish Rdoc Generator 2.