Class: HerokuDroid

Inherits:
Droid
  • Object
show all
Defined in:
lib/droid/heroku.rb

Constant Summary

Constants inherited from Droid

Droid::DEFAULT_TTL

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Droid

bunny, call, closing?, default_config, gen_queue, handle_error, log, #log, log=, name, name=, pop, publish, #publish, publish_to_ex, publish_to_q, reconnect_on_error, reset_bunny, start, stop_safe, version, wait_for_tcp_port

Methods included from Droid::EMTimerUtils

included, #periodic_timer, #timer

Methods included from Droid::BackwardsCompatibleMethods

#listen4

Methods included from Droid::QueueMethods

#listener, #worker

Constructor Details

#initialize(name, opts = {}, &blk) ⇒ HerokuDroid

Returns a new instance of HerokuDroid.



29
30
31
32
33
34
35
36
37
 
# File 'lib/droid/heroku.rb', line 29

def initialize(name, opts={}, &blk)
  @extended_stats = !(opts[:extended_stats] == false)

  super(name, opts) do |droid|
    setup_standard_topics(self) unless opts[:standard_topics] == false
    LocalStats.attach
    blk.call(self)
  end
end

Instance Attribute Details

#extended_stats ⇒ Object (readonly)

Returns the value of attribute extended_stats.



27
28
29
 
# File 'lib/droid/heroku.rb', line 27

def extended_stats
  @extended_stats
end

Instance Method Details

#call_stats ⇒ Object 



46
47
48
 
# File 'lib/droid/heroku.rb', line 46

def call_stats
  @stats ? @stats.call : nil
end

#name ⇒ Object 



50
51
52
 
# File 'lib/droid/heroku.rb', line 50

def name
  Droid.name
end

#ruby_path ⇒ Object 



54
55
56
57
58
59
60
 
# File 'lib/droid/heroku.rb', line 54

def ruby_path
  if File.exists?("/usr/ruby1.8.6/bin/ruby")
    "/usr/ruby1.8.6/bin"
  else
    "/usr/local/bin"
  end
end

#setup_ping_topic(droid) ⇒ Object 



66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/droid/heroku.rb', line 66

def setup_ping_topic(droid)
  require 'time'

  droid.listener('ping').subscribe do |req|
    Droid::Utilization.latency = (Time.now.to_f - req['departed_at']).abs
  end

  blk = Proc.new do |d|
    begin
      t1 = Time.now
      response = {}.merge(LocalStats.stats)

      estats = nil
      if self.extended_stats
        estats = droid.call_stats
        estats = { :notes => estats } unless estats.kind_of?(Hash)
        estats[:notes] ||= estats.map { |k, v| "#{v} #{k}" }.join(", ")
        estats.merge!(LocalStats.extended_stats)
      end

      response.merge!({
        :extended_stats => estats,
        :droid_name => Droid.name,
        :latency => Droid::Utilization.latency,
      })

      d.publish('pong', response.merge(:stat_collection => (Time.now - t1)))
    rescue Object => e
      log.error "Ping Block Error: #{e.class} -> #{e.message}", :exception => e
    end
  end

  EM.add_timer(2) { blk.call(droid) }
  EM.add_periodic_timer(50 + (rand*15).to_i) { blk.call(droid) }
end

#setup_standard_topics(droid) ⇒ Object 



62
63
64
 
# File 'lib/droid/heroku.rb', line 62

def setup_standard_topics(droid)
  setup_ping_topic(droid)
end

#stats(&blk) ⇒ Object 



39
40
41
42
43
44
 
# File 'lib/droid/heroku.rb', line 39

def stats(&blk)
  @stats = blk
  out = call_stats
  out = out.inspect unless out.kind_of?(String)
  Log.notice out
end