Class: LogStash::Util::WrappedAckedQueue::WriteClient
- Inherits:
-
Object
- Object
- LogStash::Util::WrappedAckedQueue::WriteClient
- Defined in:
- lib/logstash/util/wrapped_acked_queue.rb
Instance Method Summary collapse
- #get_new_batch ⇒ Object
-
#initialize(queue) ⇒ WriteClient
constructor
A new instance of WriteClient.
- #push(event) ⇒ Object (also: #<<)
- #push_batch(batch) ⇒ Object
Constructor Details
#initialize(queue) ⇒ WriteClient
Returns a new instance of WriteClient.
315 316 317 |
# File 'lib/logstash/util/wrapped_acked_queue.rb', line 315 def initialize(queue) @queue = queue end |
Instance Method Details
#get_new_batch ⇒ Object
319 320 321 |
# File 'lib/logstash/util/wrapped_acked_queue.rb', line 319 def get_new_batch WriteBatch.new end |
#push(event) ⇒ Object Also known as: <<
323 324 325 326 327 328 |
# File 'lib/logstash/util/wrapped_acked_queue.rb', line 323 def push(event) if @queue.closed? raise QueueClosedError.new("Attempted to write an event to a closed AckedQueue") end @queue.push(event) end |
#push_batch(batch) ⇒ Object
331 332 333 334 335 336 337 338 |
# File 'lib/logstash/util/wrapped_acked_queue.rb', line 331 def push_batch(batch) if @queue.closed? raise QueueClosedError.new("Attempted to write a batch to a closed AckedQueue") end batch.each do |event| push(event) end end |