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