Sha256: 7da738613541d0957b76a438bb3291d7a41dd328188c3a377368b32a3a787869
Contents?: true
Size: 1.54 KB
Versions: 7
Compression:
Stored size: 1.54 KB
Contents
require 'uri'
begin
require 'statsd-ruby'
rescue LoadError
raise 'Gem statsd-ruby is required for logging metrics. Please add the gem "statsd-ruby" to your Gemfile.'
end
module SemanticLogger
module Metrics
class Statsd < Subscriber
# Create Statsd metrics subscriber
#
# Parameters:
# url: [String]
# Valid URL to post to.
# Example:
# udp://localhost:8125
# Example, send all metrics to a particular namespace:
# udp://localhost:8125/namespace
# Default: udp://localhost:8125
#
# Example:
# subscriber = SemanticLogger::Metrics::Statsd.new(url: 'udp://localhost:8125')
# SemanticLogger.on_metric(subscriber)
def initialize(options = {})
options = options.dup
@url = options.delete(:url) || 'udp://localhost:8125'
uri = URI.parse(@url)
raise('Statsd only supports udp. Example: "udp://localhost:8125"') if uri.scheme != 'udp'
@statsd = ::Statsd.new(uri.host, uri.port)
path = uri.path.chomp('/')
@statsd.namespace = path.sub('/', '') if path != ''
end
def call(log)
metric = log.metric
if duration = log.duration
@statsd.timing(metric, duration)
else
amount = (log.metric_amount || 1).round
if amount < 0
amount.times { @statsd.decrement(metric) }
else
amount.times { @statsd.increment(metric) }
end
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems