Contents

require 'uri'
begin
  require 'statsd-ruby'
rescue LoadError
  raise LoadError.new('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

2 entries across 2 versions & 1 rubygems

Version	Path
semantic_logger-4.6.1	lib/semantic_logger/metric/statsd.rb
semantic_logger-4.6.0	lib/semantic_logger/metric/statsd.rb