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 



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

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

Instance Method Details

#close ⇒ Object 



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

def close
  @delegate.close
end

#events ⇒ Object 



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

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

#filteredSize ⇒ Object 



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

def filteredSize
  @delegate.to_java.filtered_size
end

#merge(event) ⇒ Object 



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

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

#to_a ⇒ Object 



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

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