Class: Stackify::Metrics::MetricsSender

Inherits:
HttpClient show all
Defined in:
lib/stackify/metrics/metrics_sender.rb

Constant Summary collapse

SUBMIT_METRIS_URI = 
URI("#{Stackify.configuration.base_api_url}/Metrics/SubmitMetricsByID")
GET_METRIC_INFO_URI = 
URI("#{Stackify.configuration.base_api_url}/Metrics/GetMetricInfo")

Constants inherited from HttpClient

HttpClient::HEADERS

Instance Attribute Summary

Attributes inherited from HttpClient

#errors, #response

Instance Method Summary collapse

Instance Method Details

#monitor_info(aggr_metric) ⇒ Object 



6
7
8
9
10
11
12
 
# File 'lib/stackify/metrics/metrics_sender.rb', line 6

def monitor_info aggr_metric
  if Stackify.authorized?
    send_request GET_METRIC_INFO_URI, GetMetricRequest.new(aggr_metric).to_h.to_json
  else
    Stackify.log_internal_error "Getting of monitor_info is failed because of authorization failure"
  end
end

#upload_metrics(aggr_metrics) ⇒ Object 



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
 
# File 'lib/stackify/metrics/metrics_sender.rb', line 14

def upload_metrics aggr_metrics
  return true if aggr_metrics.nil? || aggr_metrics.length == 0
  current_time = Stackify::Utils.rounded_current_time
  if Stackify.authorized?
    records = []
    aggr_metrics.each_pair do |_key, metric|
      next if metric.sent || metric.occurred_utc.to_i >= current_time.to_i
      records << Stackify::Metrics::MetricForSubmit.new(metric).to_h
      metric.sent = true
    end
    if records.any?
      Stackify.internal_log :debug, "Uploading Aggregate Metrics at #{ Time.now }: \n" + JSON.pretty_generate(records)
      response = send_request SUBMIT_METRIS_URI, records.to_json
      Stackify.internal_log :info, 'Metrics are uploaded successfully' if response.try(:status) == 200
    end
  else
    Stackify.log_internal_error "Uploading of metrics is failed because of authorization failure"
  end
end