Method: Fluent::Plugin::Buffer#queue_full?

Defined in:
lib/fluent/plugin/buffer.rb

#queue_full? ⇒ Boolean

Returns:

  • (Boolean) 


462
463
464
 
# File 'lib/fluent/plugin/buffer.rb', line 462

def queue_full?
  synchronize { @queue.size } >= @queued_chunks_limit_size
end