Class: GroongaQueryLog::Replayer
- Inherits:
-
Object
- Object
- GroongaQueryLog::Replayer
- Defined in:
- lib/groonga-query-log/replayer.rb
Defined Under Namespace
Classes: NullOutput, Options
Instance Method Summary collapse
-
#initialize(options) ⇒ Replayer
constructor
A new instance of Replayer.
- #replay(input) ⇒ Object
Constructor Details
#initialize(options) ⇒ Replayer
Returns a new instance of Replayer.
26 27 28 29 30 |
# File 'lib/groonga-query-log/replayer.rb', line 26 def initialize() @options = @queue = SizedQueue.new(@options.request_queue_size) @responses = Queue.new end |
Instance Method Details
#replay(input) ⇒ Object
32 33 34 35 36 37 38 39 |
# File 'lib/groonga-query-log/replayer.rb', line 32 def replay(input) producer = run_producer(input) consumers = run_consumers response_logger = run_response_logger producer.join consumers.each(&:join) response_logger.join end |