Module: Droid::Utilization

Extended by:
Utilization
Included in:
Utilization
Defined in:
lib/droid/utilization.rb

Constant Summary collapse

@@start = 
Time.now.getutc
@@data = 
{ }

Instance Method Summary collapse

Instance Method Details

#calc_utilization(topic, t2 = nil) ⇒ Object 



39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/droid/utilization.rb', line 39

def calc_utilization(topic, t2=nil)
  d = data(topic)
  t1 = @@start
  t2 ||= Time.now.getutc.to_i
  secs = (t2 - t1)
  secs = 1 if secs <= 0.0
  if d['msgs'] == 0
    avg = 0.0
  else
    avg = d['time'] / d['msgs']
  end
  utilization = d['time'] / secs
  {
    'avg' => avg,
    'secs' => secs,
    'utilization' => utilization,
    'msgs' => d['msgs'],
    'msgs_per_sec' => d['msgs'] / secs
  }
end

#data(topic) ⇒ Object 



21
22
23
24
25
26
27
 
# File 'lib/droid/utilization.rb', line 21

def data(topic)
  @@data[topic] ||= {
    'msgs' => 0,
    'time' => 0.0
  }
  @@data[topic]
end

#latency ⇒ Object 



7
 
# File 'lib/droid/utilization.rb', line 7

def latency; @latency; end

#latency=(val) ⇒ Object 



6
 
# File 'lib/droid/utilization.rb', line 6

def latency=(val); @latency = val; end

#monitor(topic, opts = {}) ⇒ Object 



60
61
62
63
64
65
66
67
68
69
70
 
# File 'lib/droid/utilization.rb', line 60

def monitor(topic, opts={})
  topic = 'temporary' if opts[:temp]

  t1 = Time.now.getutc
  begin
    yield if block_given?
  ensure
    t2 = Time.now.getutc
    record(topic, t2 - t1)
  end
end

#record(topic, secs) ⇒ Object 



33
34
35
36
37
 
# File 'lib/droid/utilization.rb', line 33

def record(topic, secs)
  d = data(topic)
  d['msgs'] += 1
  d['time'] += secs
end

#reinit ⇒ Object 



16
17
18
19
 
# File 'lib/droid/utilization.rb', line 16

def reinit
  @@start = Time.now.getutc
  @@data = { }
end

#report ⇒ Object 



107
108
109
110
111
 
# File 'lib/droid/utilization.rb', line 107

def report
  data = report_data
  summary = report_summary(data)
  { 'data' => data, 'summary' => summary }
end

#report_data ⇒ Object 



72
73
74
75
76
77
78
79
 
# File 'lib/droid/utilization.rb', line 72

def report_data
  data = {}
  t2 = Time.now.getutc
  topics.each do |topic|
    data[topic] = calc_utilization(topic, t2)
  end
  data
end

#report_summary(data = nil) ⇒ Object 



81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/droid/utilization.rb', line 81

def report_summary(data=nil)
  data ||= report_data

  summary = {
    'avg' => 0.0,
    'utilization' => 0.0,
    'msgs' => 0,
    'msgs_per_sec' => 0.0,
    'secs' => 0.0
  }
  data.each do |topic, d|
    summary['utilization'] += d['utilization']
    summary['msgs'] += d['msgs']
    summary['msgs_per_sec'] += d['msgs_per_sec']
    summary['avg'] += d['avg']
    summary['secs'] += d['secs']
  end
  if data.size < 1
    summary['avg'] = 0.0
  else
    summary['avg'] /= data.size
  end

  summary
end

#start ⇒ Object 



12
13
14
 
# File 'lib/droid/utilization.rb', line 12

def start
  @@start
end

#topics ⇒ Object 



29
30
31
 
# File 'lib/droid/utilization.rb', line 29

def topics
  @@data.keys
end