Method: Fluent::Plugin::Buffer#queued?

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

#queued?(metadata = nil, optimistic: false) ⇒ Boolean

Returns:

  • (Boolean) 


470
471
472
473
474
475
476
477
478
 
# File 'lib/fluent/plugin/buffer.rb', line 470

def queued?(metadata = nil, optimistic: false)
  if optimistic
    optimistic_queued?(metadata)
  else
    synchronize do
      optimistic_queued?(metadata)
    end
  end
end