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

#callObject



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_factorObject



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