Class: Kronk::Player::Benchmark

Inherits:

Kronk::Player

• Object
• QueueRunner
• Kronk::Player
• Kronk::Player::Benchmark

Defined in:

lib/kronk/player/benchmark.rb

Overview

Returns benchmarks for a set of Player results.

• Total time taken

• Complete requests

• Failed requests

• Total bytes transferred

• Requests per second

• Time per request

• Transfer rate

• Connection times (min mean median max)

• Percentage of requests within a certain time

• Slowest endpoints

Defined Under Namespace

Classes: ResultSet

Instance Attribute Summary

Attributes inherited from Kronk::Player

#concurrency, #input, #mutex, #qps

Attributes inherited from QueueRunner

#count, #number, #queue, #reader_thread, #threads

Instance Method Summary

• #body ⇒ Object
• #clear_screen ⇒ Object
• #complete ⇒ Object
• #error(err, kronk) ⇒ Object
• #head ⇒ Object
• #render ⇒ Object
• #result(kronk) ⇒ Object
• #start ⇒ Object

Methods inherited from Kronk::Player

#compare, #from_io, #initialize, new_type, #request, #run, #trigger_result

Methods inherited from QueueRunner

#concurrently, #finish, #finished?, #initialize, #kill, #on, #periodically, #start_input!, #stop_input!, #trigger, #until_finished, #yield_queue_item

Constructor Details

This class inherits a constructor from Kronk::Player

Instance Method Details

#body ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 274

def body
  @results.each{|res| res.total_time = Time.now - @start_time }

  if @results.length > 1
    Diff.new(@results[0].to_s, @results[1].to_s, :context => false).
      formatted
  else
    @results.first.to_s
  end
end

#clear_screen ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 241

def clear_screen
  $stdout.print "\e[2K\e[1A" * @line_count
end

#complete ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 256

def complete
  puts "Finished!" unless @interactive

  render
  true
end

#error(err, kronk) ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 246

def error err, kronk
  @mutex.synchronize do
    @res_count += 1
    @results.each do |res|
      res.err_count += 1
    end
  end
end

#head ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 286

def head
  <<-STR

Benchmark Time:      #{(Time.now - @start_time).to_f} sec
Number of Requests:  #{@count}
Concurrency:         #{@qps ? "#{@qps} qps" : @concurrency}
#{"Current Connections: #{Kronk::HTTP.conn_count}\n" if @interactive}\
Total Connections:   #{Kronk::HTTP.total_conn}
  STR
end

#render ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 264

def render
  clear_screen if @interactive
  out = "#{head}#{body}\n"
  @line_count = out.to_s.split("\n").length
  @last_print = Time.now
  $stdout.print out
  $stdout.flush
end

#result(kronk) ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 223

def result kronk
  @mutex.synchronize do
    kronk.responses.each_with_index do |resp, i|
      @results[i] ||= ResultSet.new
      @results[i].add_result resp
    end

    @res_count += 1

    if @interactive
      render if Time.now - @last_print > 0.5
    else
      puts "#{@res_count} requests" if @res_count % @div == 0
    end
  end
end

#start ⇒ Object

# File 'lib/kronk/player/benchmark.rb', line 210

def start
  @interactive = $stdout.isatty
  @res_count   = 0
  @results     = [ResultSet.new]
  @div         = @number / 10 if @number
  @div         = 100 if !@div || @div < 10
  @last_print  = Time.now
  @line_count  = 0

  puts "Benchmarking..." unless @interactive
end