Sha256: 095194d39b6b9780ad4c01ed33c93371eed4d7c129213c91143d7e06ad483cae
Contents?: true
Size: 1.75 KB
Versions: 15
Compression:
Stored size: 1.75 KB
Contents
require "uri"
begin
require "statsd-ruby"
rescue LoadError
raise LoadError, 'Gem statsd-ruby is required for logging metrics. Please add the gem "statsd-ruby" to your Gemfile.'
end
module SemanticLogger
module Metric
class Statsd < Subscriber
attr_accessor :url
# 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:
# SemanticLogger.add_appender(
# metric: :statsd,
# url: 'localhost:8125'
# )
def initialize(url: "udp://localhost:8125")
@url = url
end
def reopen
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 log(log)
metric = log.metric
if (duration = log.duration)
@statsd.timing(metric, duration)
else
amount = (log.metric_amount || 1).round
if amount.negative?
amount.times { @statsd.decrement(metric) }
else
amount.times { @statsd.increment(metric) }
end
end
end
# Only forward log entries that contain metrics.
def should_log?(log)
# Does not support metrics with dimensions.
log.metric && !log.dimensions && meets_log_level?(log) && !filtered?(log)
end
end
end
end
Version data entries
15 entries across 15 versions & 1 rubygems