Parent

Methods

Class/Module Index [+]

Quicksearch

Fluent::DetachProcessManager::Forwarder

Public Class Methods

new(w) click to toggle source
# File lib/fluent/process.rb, line 223
def initialize(w)
  @w = w
end

Public Instance Methods

emit(tag, es) click to toggle source
# File lib/fluent/process.rb, line 227
def emit(tag, es)
  ms = es.to_msgpack_stream
  #[tag, ms].to_msgpack(@w)  # not thread safe
  @w.write [tag, ms].to_msgpack
end

[Validate]

Generated with the Darkfish Rdoc Generator 2.