Module: Fluent::Compat::TimeSliceChunkMixin

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

Instance Method Summary collapse

Instance Method Details

#write(chunk) ⇒ Object

prepend this module to TimeSlicedOutput plugin singleton class



137
138
139
140
141
142
143
144
145
146
 
# File 'lib/fluent/compat/output.rb', line 137

def write(chunk)
  chunk.extend(ChunkSizeCompatMixin)
  chunk.extend(ChunkMessagePackEventStreamer)
  chunk.extend(AddTimeSliceKeyToChunkMixin)
  chunk.time_slice_format = @time_slice_format
  chunk.timekey = @_timekey
  chunk.timezone = @timezone
  chunk.assume_timekey!
  super
end