Class: EventHub::Statistics

Inherits:
Object
  • Object
show all
Defined in:
lib/eventhub/statistics.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Statistics

Returns a new instance of Statistics.



4
5
6
7
8
9
10
11
 
# File 'lib/eventhub/statistics.rb', line 4

def initialize
  @messages_successful = 0
  @messages_unsuccessful = 0
  @messages_average_size = 0
  @messages_average_process_time = 0
  @messages_total_process_time = 0
  @mutex = Mutex.new
end

Instance Attribute Details

#messages_average_process_time ⇒ Object (readonly)

Returns the value of attribute messages_average_process_time.



2
3
4
 
# File 'lib/eventhub/statistics.rb', line 2

def messages_average_process_time
  @messages_average_process_time
end

#messages_average_size ⇒ Object (readonly)

Returns the value of attribute messages_average_size.



2
3
4
 
# File 'lib/eventhub/statistics.rb', line 2

def messages_average_size
  @messages_average_size
end

#messages_successful ⇒ Object (readonly)

Returns the value of attribute messages_successful.



2
3
4
 
# File 'lib/eventhub/statistics.rb', line 2

def messages_successful
  @messages_successful
end

#messages_unsuccessful ⇒ Object (readonly)

Returns the value of attribute messages_unsuccessful.



2
3
4
 
# File 'lib/eventhub/statistics.rb', line 2

def messages_unsuccessful
  @messages_unsuccessful
end

Instance Method Details

#failure ⇒ Object 



32
33
34
35
36
37
 
# File 'lib/eventhub/statistics.rb', line 32

def failure
  @mutex.lock
  @messages_unsuccessful += 1
ensure
  @mutex.unlock
end

#measure(size, &block) ⇒ Object 



13
14
15
16
17
18
19
20
 
# File 'lib/eventhub/statistics.rb', line 13

def measure(size, &block)
  start = Time.now
  yield
  success(Time.now - start, size)
rescue
  failure
  raise
end

#messages_total ⇒ Object 



39
40
41
 
# File 'lib/eventhub/statistics.rb', line 39

def messages_total
  messages_unsuccessful + messages_successful
end

#messages_total_process_time ⇒ Object 



43
44
45
 
# File 'lib/eventhub/statistics.rb', line 43

def messages_total_process_time
  messages_average_process_time * messages_successful
end

#messages_total_size ⇒ Object 



47
48
49
 
# File 'lib/eventhub/statistics.rb', line 47

def messages_total_size
  messages_average_size * messages_successful
end

#success(process_time, size) ⇒ Object 



22
23
24
25
26
27
28
29
30
 
# File 'lib/eventhub/statistics.rb', line 22

def success(process_time, size)
  @mutex.lock
  @messages_total_process_time += process_time
  @messages_average_process_time = (messages_total_process_time + process_time) / (messages_successful + 1).to_f
  @messages_average_size = (messages_total_size + size) / (messages_successful + 1).to_f
  @messages_successful += 1
ensure
  @mutex.unlock
end