class Fluent::DetachProcessManager::Forwarder
Public Class Methods
new(w)
click to toggle source
# File lib/fluent/process.rb, line 230 def initialize(w) @w = w end
Public Instance Methods
emit(tag, es)
click to toggle source
# File lib/fluent/process.rb, line 234 def emit(tag, es) ms = es.to_msgpack_stream #[tag, ms].to_msgpack(@w) # not thread safe @w.write [tag, ms].to_msgpack end