Class: RequestResponseStats::ReqResStat

Inherits:
Object
  • Object
show all
Includes:
Mongoid::Document
Defined in:
lib/request_response_stats/req_res_stat.rb

Constant Summary collapse

DEFAULT_STATS_GRANULARITY = 
1.hour
PERCISION = 
2

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.get_avg(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY) ⇒ Object

wrapper around get_stat for :avg stat for more info, check documentation for get_stat



88
89
90
91
92
93
94
95
96
97
98
99
100
 
# File 'lib/request_response_stats/req_res_stat.rb', line 88

def get_avg(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY)
  data = get_stat("sum", key, start_time, end_time, granularity)
  data.each do |e|
    e[:stat_type] = "avg"
    if e[:count] != 0
      e[:data] = (e[:data] * 1.0 / e[:count]).try(:round, PERCISION)
    else
      e[:data] = 0
    end

  end
  data
end

.get_details(key, start_time, end_time, stat_type = nil, granularity = DEFAULT_STATS_GRANULARITY) ⇒ Object

instead of aggregated values (such as in get_stat), it returns grouped values for given key, given granularity level, and given start_time and end_time set stat_type as nil to return grouped but uncompacted data otherwise, you can set stat_type as :sum, :max, :min, :avg to get grouped data TODO: Ignore start_time and end_time if a time-based collection is passed TODO: Optimize get_time_ranges to not to calculate time_ranges again and again for same start_time and end_time (that is, for same time-based collection



109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
 
# File 'lib/request_response_stats/req_res_stat.rb', line 109

def get_details(key, start_time, end_time, stat_type = nil, granularity = DEFAULT_STATS_GRANULARITY)
  # get ungrouped data
  stat_type = stat_type.to_s.to_sym if stat_type
  key = key.to_s.to_sym
  relevant_records = get_within(start_time, end_time)
  time_ranges = get_time_ranges(start_time, end_time, granularity)
  stats = time_ranges.map do |time_range|
    data_for_time_range = relevant_records.get_within(*time_range.values).map{ |r|
      {server_plus_api: r.server_plus_api, data: r[key], key_name: r.key_name}
    }
    {data: data_for_time_range, **time_range}
  end

  # grouping data by :server_plus_api
  stats.each do |r|
    data = r[:data]
    data = data.map{ |e| {server_plus_api: e[:server_plus_api], data: e[:data]} }
    data = data.group_by { |e| e[:server_plus_api] }
    r[:data] = data
  end

  # calculating grouped value based on stat_type
  if stat_type
    if [:sum, :min, :max].include? stat_type

      # calculate grouped value
      stats.each do |r|
        data = r[:data]
        data = data.map do |k, v|
          # {server_plus_api: k, data: v.map{|e| e[:data]}}
          element_data = v.map{|e| e[:data]}
          {server_plus_api: k, count: element_data.size, data: element_data.compact.public_send(stat_type).try(:round, PERCISION)}
        end
        r[:data] = data
      end

      stats
    elsif stat_type == :avg
      data = get_details(key, start_time, end_time, stat_type = :sum, granularity)
      data.each do |r|
        r[:data].each do |e|
          e[:data] = (e[:data] * 1.0 / e[:count]).try(:round, PERCISION)
        end
      end

      data
    else
      "This :stat_type is not supported"
    end
  else
    stats
  end
end

.get_max(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY) ⇒ Object

wrapper around get_stat for :max stat for more info, check documentation for get_stat



82
83
84
 
# File 'lib/request_response_stats/req_res_stat.rb', line 82

def get_max(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY)
  get_stat("max", key, start_time, end_time, granularity)
end

.get_min(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY) ⇒ Object

wrapper around get_stat for :min stat for more info, check documentation for get_stat



76
77
78
 
# File 'lib/request_response_stats/req_res_stat.rb', line 76

def get_min(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY)
  get_stat("min", key, start_time, end_time, granularity)
end

.get_sum(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY) ⇒ Object

wrapper around get_stat for :sum stat for more info, check documentation for get_stat



70
71
72
 
# File 'lib/request_response_stats/req_res_stat.rb', line 70

def get_sum(key, start_time, end_time, granularity = DEFAULT_STATS_GRANULARITY)
  get_stat("sum", key, start_time, end_time, granularity)
end

.get_within(start_time, end_time) ⇒ Object

Note: start_time and end_time are Time objects start_time in inclusive but end_time is not Use get_within with nil values for start_time and end_time to minimize database hits for same kind of queries on same date-range of data



60
61
62
63
64
65
66
 
# File 'lib/request_response_stats/req_res_stat.rb', line 60

def get_within(start_time, end_time)
  if start_time || end_time
    where(:start_time.gte => start_time, :end_time.lt => end_time)
  else
    all
  end
end

Instance Method Details

#server_plus_api ⇒ Object

returns a string identifying server_name, api_name, and api_verb



50
51
52
 
# File 'lib/request_response_stats/req_res_stat.rb', line 50

def server_plus_api
  [server_name, api_name, api_verb].join("_")
end