Class: Benchmark::HTTP::Command::Latency
- Inherits:
-
Samovar::Command
- Object
- Samovar::Command
- Benchmark::HTTP::Command::Latency
- Defined in:
- lib/benchmark/http/command/latency.rb
Instance Method Summary collapse
- #call ⇒ Object
- #confidence_factor ⇒ Object
- #measure_performance(concurrency, endpoint, request_path) ⇒ Object
- #run(url) ⇒ Object
Instance Method Details
#call ⇒ Object
86 87 88 89 90 |
# File 'lib/benchmark/http/command/latency.rb', line 86 def call @hosts.each do |host| run(host).wait end end |
#confidence_factor ⇒ Object
43 44 45 |
# File 'lib/benchmark/http/command/latency.rb', line 43 def confidence_factor 1.0 - @options[:confidence] end |
#measure_performance(concurrency, endpoint, request_path) ⇒ Object
47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 |
# File 'lib/benchmark/http/command/latency.rb', line 47 def measure_performance(concurrency, endpoint, request_path) puts "I am running #{concurrency} asynchronous tasks that will each make sequential requests..." statistics = Statistics.new(concurrency) task = Async::Task.current concurrency.times.map do task.async do client = Async::HTTP::Client.new(endpoint, protocol: endpoint.protocol) statistics.sample(confidence_factor) do response = client.get(request_path).tap(&:finish) end client.close end end.each(&:wait) puts "I made #{statistics.count} requests in #{Seconds[statistics.sequential_duration]}. The per-request latency was #{Seconds[statistics.latency]}. That's #{statistics.per_second} asynchronous requests/second." puts "\t Variance: #{Seconds[statistics.variance]}" puts "\tStandard Deviation: #{Seconds[statistics.standard_deviation]}" puts "\t Standard Error: #{Seconds[statistics.standard_error]}" return statistics end |
#run(url) ⇒ Object
73 74 75 76 77 78 79 80 81 82 83 84 |
# File 'lib/benchmark/http/command/latency.rb', line 73 def run(url) endpoint = Async::HTTP::Endpoint.parse(url) request_path = endpoint.url.request_uri puts "I am going to benchmark #{url}..." Async::Reactor.run do |task| statistics = [] base = measure_performance(@options[:concurrency], endpoint, request_path) end end |