/usr/lib/ruby/vendor_ruby/metriks/reporter/librato_metrics.rb is in ruby-metriks 0.9.9.6-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 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 101 102 103 104 105 106 107 108 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 162 163 164 165 166 167 168 169 170 171 172 173 | require 'metriks/time_tracker'
require 'net/https'
module Metriks::Reporter
class LibratoMetrics
attr_accessor :prefix, :source
def initialize(email, token, options = {})
@email = email
@token = token
@prefix = options[:prefix]
@source = options[:source]
@registry = options[:registry] || Metriks::Registry.default
@time_tracker = Metriks::TimeTracker.new(options[:interval] || 60)
@on_error = options[:on_error] || proc { |ex| }
end
def start
@thread ||= Thread.new do
loop do
@time_tracker.sleep
Thread.new do
begin
write
rescue Exception => ex
@on_error[ex] rescue nil
end
end
end
end
end
def stop
@thread.kill if @thread
@thread = nil
end
def restart
stop
start
end
def write
gauges = []
@registry.each do |name, metric|
gauges << case metric
when Metriks::Meter
prepare_metric name, metric, [
:count, :one_minute_rate, :five_minute_rate,
:fifteen_minute_rate, :mean_rate
]
when Metriks::Counter
prepare_metric name, metric, [
:count
]
when Metriks::Gauge
prepare_metric name, metric, [
:value
]
when Metriks::UtilizationTimer
prepare_metric name, metric, [
:count, :one_minute_rate, :five_minute_rate,
:fifteen_minute_rate, :mean_rate,
:min, :max, :mean, :stddev,
:one_minute_utilization, :five_minute_utilization,
:fifteen_minute_utilization, :mean_utilization,
], [
:median, :get_95th_percentile
]
when Metriks::Timer
prepare_metric name, metric, [
:count, :one_minute_rate, :five_minute_rate,
:fifteen_minute_rate, :mean_rate,
:min, :max, :mean, :stddev
], [
:median, :get_95th_percentile
]
when Metriks::Histogram
prepare_metric name, metric, [
:count, :min, :max, :mean, :stddev
], [
:median, :get_95th_percentile
]
end
end
gauges.flatten!
unless gauges.empty?
submit(form_data(gauges.flatten))
end
end
def submit(data)
url = URI.parse('https://metrics-api.librato.com/v1/metrics')
req = Net::HTTP::Post.new(url.path)
req.basic_auth(@email, @token)
req.set_form_data(data)
http = Net::HTTP.new(url.host, url.port)
http.verify_mode = OpenSSL::SSL::VERIFY_PEER
http.use_ssl = true
store = OpenSSL::X509::Store.new
store.set_default_paths
http.cert_store = store
case res = http.start { |http| http.request(req) }
when Net::HTTPSuccess, Net::HTTPRedirection
# OK
else
res.error!
end
end
def form_data(metrics)
data = {}
metrics.each_with_index do |gauge, idx|
gauge.each do |key, value|
if value
data["gauges[#{idx}][#{key}]"] = value.to_s
end
end
end
data
end
def prepare_metric(base_name, metric, keys, snapshot_keys = [])
results = []
time = @time_tracker.now_floored
base_name = base_name.to_s.gsub(/ +/, '_')
if @prefix
base_name = "#{@prefix}.#{base_name}"
end
keys.flatten.each do |key|
name = key.to_s.gsub(/^get_/, '')
value = metric.send(key)
results << {
:type => "gauge",
:name => "#{base_name}.#{name}",
:source => @source,
:measure_time => time,
:value => value
}
end
unless snapshot_keys.empty?
snapshot = metric.snapshot
snapshot_keys.flatten.each do |key|
name = key.to_s.gsub(/^get_/, '')
value = snapshot.send(key)
results << {
:type => "gauge",
:name => "#{base_name}.#{name}",
:source => @source,
:measure_time => time,
:value => value
}
end
end
results
end
end
end
|