Class: LogStash::TestPipeline::QueueBatchDelegator

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/test_pipeline.rb

Instance Method Summary collapse

Constructor Details

#initialize(event_tracker, delegate) ⇒ QueueBatchDelegator

Returns a new instance of QueueBatchDelegator.



136
137
138
139
 
# File 'lib/logstash/test_pipeline.rb', line 136

def initialize(event_tracker, delegate)
  @event_tracker = event_tracker
  @delegate = delegate
end

Instance Method Details

#close ⇒ Object 



167
168
169
 
# File 'lib/logstash/test_pipeline.rb', line 167

def close
  @delegate.close
end

#events ⇒ Object 



154
155
156
157
158
159
 
# File 'lib/logstash/test_pipeline.rb', line 154

def events
  @delegate.events.tap do |events|
    # filters out rogue (cancelled) events
    @event_tracker.filtered_events events
  end
end

#filteredSize ⇒ Object 



150
151
152
 
# File 'lib/logstash/test_pipeline.rb', line 150

def filteredSize
  @delegate.to_java.filtered_size
end

#merge(event) ⇒ Object 



162
163
164
 
# File 'lib/logstash/test_pipeline.rb', line 162

def merge(event)
  @delegate.merge(event)
end

#to_a ⇒ Object 



142
143
144
145
146
147
 
# File 'lib/logstash/test_pipeline.rb', line 142

def to_a
  @delegate.to_a.tap do |events|
    # filters out rogue (cancelled) events
    @event_tracker.filtered_events events
  end
end