Module: Fluent::Compat::BufferedChunkMixin

Defined in:
lib/fluent/compat/output.rb

Instance Method Summary collapse

Instance Method Details

#write(chunk) ⇒ Object

prepend this module to BufferedOutput (including ObjectBufferedOutput) plugin singleton class



127
128
129
130
131
132
 
# 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