Contents

module Datadog::Notifications::Plugins
  class GRPC < Base

    # Options:
    #
    # *<tt>:metric_name</tt> - the metric name, defaults to 'grpc.request'
    # *<tt>:tags</tt> - additional tags
    #
    # It expects ActiveSupport instrumented notifications named 'process_action.grpc'.
    # Each such notification should have an :action key with gRPC action (method) name.
    #
    # Compatible instrumentation is implemented in grpcx gem: https://github.com/bsm/grpcx
    def initialize(opts={})
      super
      @metric_name = opts[:metric_name] || 'grpc.request'

      Datadog::Notifications.subscribe 'process_action.grpc' do |reporter, event|
        record reporter, event
      end
    end

    private

    def record(reporter, event)
      payload = event.payload
      action  = payload[:action]
      status  = payload[:exception] ? 'error' : 'ok'

      tags = self.tags + %W[action:#{action} status:#{status}]

      reporter.batch do
        reporter.increment @metric_name, tags: tags
        reporter.timing "#{@metric_name}.time", event.duration, tags: tags
      end
    end

  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
datadog-notifications-0.5.3	lib/datadog/notifications/plugins/grpc.rb