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.



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

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

Instance Method Details

#close ⇒ Object 



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

def close
  @delegate.close
end

#events ⇒ Object 



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

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

#filteredSize ⇒ Object 



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

def filteredSize
  @delegate.to_java.filtered_size
end

#merge(event) ⇒ Object 



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

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

#to_a ⇒ Object 



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

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