Sha256: 4918fbf9d1084a713ebce88ad2cfb4edb6a04e89736caae95c7d908c4d52d0ed
Contents?: true
Size: 1.85 KB
Versions: 10
Compression:
Stored size: 1.85 KB
Contents
require 'ddtrace/ext/app_types'
require 'ddtrace/contrib/analytics'
require 'ddtrace/contrib/grpc/ext'
module Datadog
module Contrib
module GRPC
# :nodoc:
module DatadogInterceptor
# :nodoc:
class Base < ::GRPC::Interceptor
attr_accessor :datadog_pin
def initialize(options = {})
add_datadog_pin! { |c| yield(c) if block_given? }
end
def request_response(**keywords)
trace(keywords) { yield }
end
def client_streamer(**keywords)
trace(keywords) { yield }
end
def server_streamer(**keywords)
trace(keywords) { yield }
end
def bidi_streamer(**keywords)
trace(keywords) { yield }
end
private
def add_datadog_pin!
Pin.new(
service_name,
app: Ext::APP,
app_type: Datadog::Ext::AppTypes::WEB,
tracer: -> { datadog_configuration[:tracer] }
).tap do |pin|
yield(pin) if block_given?
pin.onto(self)
end
end
def datadog_configuration
Datadog.configuration[:grpc]
end
def tracer
(datadog_pin && datadog_pin.tracer) || datadog_configuration[:tracer]
end
def service_name
(datadog_pin && datadog_pin.service_name) || datadog_configuration[:service_name]
end
def analytics_enabled?
Contrib::Analytics.enabled?(datadog_configuration[:analytics_enabled])
end
def analytics_sample_rate
datadog_configuration[:analytics_sample_rate]
end
end
require_relative 'datadog_interceptor/client'
require_relative 'datadog_interceptor/server'
end
end
end
end
Version data entries
10 entries across 10 versions & 2 rubygems