Class: LogStash::TestPipeline::EventTrackingQueueReadClientDelegator

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(delegate) ⇒ EventTrackingQueueReadClientDelegator

Returns a new instance of EventTrackingQueueReadClientDelegator.



66
67
68
69
70
 
# File 'lib/logstash/test_pipeline.rb', line 66

def initialize(delegate)
  # NOTE: can not use LogStash::MemoryReadClient#read_batch due its JavaObject wrapping
  @delegate = delegate.to_java(QueueReadClient)
  @processed_events = []
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(method, *args) ⇒ Object 



118
119
120
 
# File 'lib/logstash/test_pipeline.rb', line 118

def method_missing(method, *args)
  @delegate.public_send(method, *args)
end

Instance Attribute Details

#processed_events ⇒ Object (readonly)

Returns the value of attribute processed_events.



64
65
66
 
# File 'lib/logstash/test_pipeline.rb', line 64

def processed_events
  @processed_events
end

Instance Method Details

#addFilteredMetrics(filteredSize) ⇒ Object 



103
104
105
 
# File 'lib/logstash/test_pipeline.rb', line 103

def addFilteredMetrics(filteredSize)
  @delegate.add_filtered_metrics(filteredSize)
end

#addOutputMetrics(filteredSize) ⇒ Object 



98
99
100
 
# File 'lib/logstash/test_pipeline.rb', line 98

def addOutputMetrics(filteredSize)
  @delegate.add_output_metrics(filteredSize)
end

#close ⇒ Object 



113
114
115
 
# File 'lib/logstash/test_pipeline.rb', line 113

def close
  @delegate.close
end

#closeBatch(batch) ⇒ Object 



78
79
80
 
# File 'lib/logstash/test_pipeline.rb', line 78

def closeBatch(batch)
  @delegate.close_batch(batch)
end

#filtered_events(events) ⇒ Object 



122
123
124
 
# File 'lib/logstash/test_pipeline.rb', line 122

def filtered_events(events)
  @processed_events.concat(events)
end

#isEmpty ⇒ Object 



83
84
85
 
# File 'lib/logstash/test_pipeline.rb', line 83

def isEmpty
  @delegate.empty?
end

#newBatch ⇒ Object 



88
89
90
 
# File 'lib/logstash/test_pipeline.rb', line 88

def newBatch
  @delegate.new_batch
end

#readBatch ⇒ Object 



73
74
75
 
# File 'lib/logstash/test_pipeline.rb', line 73

def readBatch
  QueueBatchDelegator.new(self, @delegate.read_batch)
end

#reset_events! ⇒ Object 



126
127
128
 
# File 'lib/logstash/test_pipeline.rb', line 126

def reset_events!
  @processed_events = []
end

#set_batch_dimensions(batch_size, batch_delay) ⇒ Object 



108
109
110
 
# File 'lib/logstash/test_pipeline.rb', line 108

def set_batch_dimensions(batch_size, batch_delay)
  @delegate.set_batch_dimensions(batch_size, batch_delay)
end

#startMetrics(batch) ⇒ Object 



93
94
95
 
# File 'lib/logstash/test_pipeline.rb', line 93

def startMetrics(batch)
  @delegate.start_metrics(batch)
end