class Fluent::StreamOutput
obsolete
Public Instance Methods
configure(conf)
click to toggle source
Calls superclass method
Fluent::Compat::BufferedOutput#configure
# File lib/fluent/plugin/out_stream.rb, line 30 def configure(conf) compat_parameters_convert(conf, :buffer) super end
flush_secondary(secondary)
click to toggle source
# File lib/fluent/plugin/out_stream.rb, line 55 def flush_secondary(secondary) unless secondary.is_a?(StreamOutput) secondary = ReformatWriter.new(secondary) end @buffer.pop(secondary) end
format_stream(tag, es)
click to toggle source
# File lib/fluent/plugin/out_stream.rb, line 35 def format_stream(tag, es) # use PackedForward [tag, es.to_msgpack_stream].to_msgpack end
write(chunk)
click to toggle source
# File lib/fluent/plugin/out_stream.rb, line 40 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