obsolete
# File lib/fluent/plugin/out_stream.rb, line 29 def configure(conf) super end
# File lib/fluent/plugin/out_stream.rb, line 53 def flush_secondary(secondary) unless secondary.is_a?(StreamOutput) secondary = ReformatWriter.new(secondary) end @buffer.pop(secondary) end
# File lib/fluent/plugin/out_stream.rb, line 33 def format_stream(tag, es) # use PackedForward [tag, es.to_msgpack_stream].to_msgpack end
# File lib/fluent/plugin/out_stream.rb, line 38 def write(chunk) sock = connect begin opt = [1, @send_timeout.to_i].pack('I!I!') # { int l_onoff; int l_linger; } sock.setsockopt(Socket::SOL_SOCKET, Socket::SO_LINGER, opt) opt = [@send_timeout.to_i, 0].pack('L!L!') # struct timeval sock.setsockopt(Socket::SOL_SOCKET, Socket::SO_SNDTIMEO, opt) chunk.write_to(sock) ensure sock.close end end
Generated with the Darkfish Rdoc Generator 2.