github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 06:37:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

MINOR: Remove unimplemented methods from batch interface

Browse source 
Fixes #8332
This commit is contained in:
Armin 2017-10-07 18:28:42 +02:00 • committed by Armin Braun
parent 428575193f
commit e0ce2575e5
2 changed files with 0 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

12
logstash-core/lib/logstash/util/wrapped_acked_queue.rb
View file

@ -243,12 +243,6 @@ module LogStash; module Util
@generated[event] = true
end
def cancel(event)
# TODO: disabled for https://github.com/elastic/logstash/issues/6055 - will have to properly refactor
raise("cancel is unsupported")
# @cancelled[event] = true
end
def to_a
events = []
each {|e| events << e}
@ -278,12 +272,6 @@ module LogStash; module Util
@originals.size + @generated.size
end
def cancelled_size
# TODO: disabled for https://github.com/elastic/logstash/issues/6055 = will have to properly refactor
raise("cancelled_size is unsupported ")
# @cancelled.size
end
def shutdown_signal_received?
false
end

12
logstash-core/lib/logstash/util/wrapped_synchronous_queue.rb
View file

@ -138,12 +138,6 @@ module LogStash; module Util
@originals.add(event)
end
def cancel(event)
# TODO: disabled for https://github.com/elastic/logstash/issues/6055 - will have to properly refactor
raise("cancel is unsupported")
# @cancelled[event] = true
end
def to_a
events = []
@originals.each {|e| events << e unless e.cancelled?}
@ -161,12 +155,6 @@ module LogStash; module Util
end
alias_method(:size, :filtered_size)
def cancelled_size
# TODO: disabled for https://github.com/elastic/logstash/issues/6055 = will have to properly refactor
raise("cancelled_size is unsupported ")
# @cancelled.size
end
end
class WriteClient