Class: Benchmark::HTTP::Command::Latency

Inherits:
Samovar::Command
  • Object
show all
Defined in:
lib/benchmark/http/command/latency.rb

Instance Method Summary collapse

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