class Fluent::LighteningBuffer

Public Instance Methods

configure(conf) click to toggle source
Calls superclass method
# File lib/fluent/plugin/buf_lightening.rb, line 23
def configure(conf)
  super
end
new_chunk(key) click to toggle source
# File lib/fluent/plugin/buf_lightening.rb, line 27
def new_chunk(key)
  LighteningBufferChunk.new(key)
end
storable?(chunk, data) click to toggle source
# File lib/fluent/plugin/buf_lightening.rb, line 31
def storable?(chunk, data)
  return false if chunk.size + data.bytesize > @buffer_chunk_limit
  return false if @buffer_chunk_records_limit && chunk.record_counter >= @buffer_chunk_records_limit
  true
end