Stats processor file for Pushr

lib-pushr-stats_processor.rb

require 'librato/metrics'
require_relative 'metrics'

module Pushr
  class StatsProcessor
    # name, start, finish, id, payload
    def call(_, start, finish, _, payload)
      messagetype = payload[:type]['Pushr::Message'.size, payload[:type].size].downcase
      hsh = { measure_time: Time.now, value: ((finish - start) * 1000) }
      Pushr::Metrics.queue.add "#{payload[:app]}:message:#{messagetype}:time" => hsh
    end
  end
end

Librato::Metrics.authenticate ENV['LIBRATO_EMAIL'], ENV['LIBRATO_KEY']
Pushr::Metrics.queue_constructor = Librato::Metrics::Queue.method(:new)
Pushr::Metrics.logger            = ::Pushr::Daemon.logger
Pushr::Metrics.exception_handler = ::Airbrake.method(:notify) if defined?(::Airbrake)

ActiveSupport::Notifications.subscribe('message', Pushr::StatsProcessor.new)