Class: KingKong::Processor::Nosey

Inherits:
Base
  • Object
show all
Defined in:
lib/kingkong/processor.rb

Instance Method Summary collapse

Constructor Details

#initialize(host = '/tmp/kingkong.socket', port = nil) ⇒ Nosey

include ::Nosey::Instrumentation



21
22
23
 
# File 'lib/kingkong/processor.rb', line 21

def initialize(host='/tmp/kingkong.socket',port=nil)
  EventMachine::Nosey::SocketServer.start(nosey.report, host, port)
end

Instance Method Details

#nosey ⇒ Object 



38
39
40
 
# File 'lib/kingkong/processor.rb', line 38

def nosey
  @nosey ||= ::Nosey::Probe::Set.new('pinger')
end

#process(ping, name) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/kingkong/processor.rb', line 25

def process(ping,name)
  nosey.increment "#{name}_ping_count"
  case ping.status
  when :timed_out
    nosey.increment "#{name}_ping_timed_out_count"
  when :completed
    nosey.increment "#{name}_ping_completed_count"
    nosey.avg "#{name}_ping_avg_latency", ping.latency
    nosey.min "#{name}_ping_min_latency", ping.latency
    nosey.max "#{name}_ping_max_latency", ping.latency
  end
end