# File lib/fluent/process.rb, line 242 def emit(tag, es) if ms = @buffer[tag] ms << es.to_msgpack_stream else @buffer[tag] = es.to_msgpack_stream end end
# File lib/fluent/process.rb, line 250 def run while true sleep @interval @buffer.keys.each {|tag| if ms = @buffer.delete(tag) [tag, ms].to_msgpack(@w) #@w.write [tag, ms].to_msgpack end } end rescue $log.error "error on forwerder thread", :error=>$!.to_s $log.error_backtrace raise end
Generated with the Darkfish Rdoc Generator 2.