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



124
125
126
127
128
 
# File 'lib/fluent/compat/output.rb', line 124

def write(chunk)
  chunk.extend(ChunkSizeCompatMixin)
  chunk.extend(AddKeyToChunkMixin) if chunk.metadata.variables && chunk.metadata.variables.has_key?(:key)
  super
end