Class: Fluent::LighteningBuffer

Inherits:
MemoryBuffer
  • Object
show all
Defined in:
lib/fluent/plugin/buf_lightening.rb

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



23
24
25
 
# File 'lib/fluent/plugin/buf_lightening.rb', line 23

def configure(conf)
  super
end

#new_chunk(key) ⇒ Object 



27
28
29
 
# File 'lib/fluent/plugin/buf_lightening.rb', line 27

def new_chunk(key)
  LighteningBufferChunk.new(key)
end

#storable?(chunk, data) ⇒ Boolean

Returns:

  • (Boolean) 


31
32
33
34
35
 
# 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