module Fluent::Compat::BufferedChunkMixin
Public Instance Methods
write(chunk)
click to toggle source
prepend this module to BufferedOutput
(including ObjectBufferedOutput
) plugin singleton class
Calls superclass method
# File lib/fluent/compat/output.rb, line 127 def write(chunk) chunk.extend(ChunkSizeCompatMixin) chunk.extend(ChunkMessagePackEventStreamer) chunk.extend(AddKeyToChunkMixin) if chunk.metadata.variables && chunk.metadata.variables.has_key?(:key) super end