Sha256: 665a337f519343f1e42689aedf4678cb069304ce0aa5547c2aaa58fcf1a31936
Contents?: true
Size: 1.9 KB
Versions: 10
Compression:
Stored size: 1.9 KB
Contents
require 'ddtrace/contrib/patcher'
require 'ddtrace/contrib/grpc/ext'
module Datadog
module Contrib
module GRPC
# Patcher enables patching of 'grpc' module.
module Patcher
include Contrib::Patcher
module_function
def target_version
Integration.version
end
def patch
require 'ddtrace/propagation/grpc_propagator'
require 'ddtrace/contrib/grpc/datadog_interceptor'
require 'ddtrace/contrib/grpc/intercept_with_datadog'
add_pin!
prepend_interceptor
end
def add_pin!
DeprecatedPin.new(
get_option(:service_name),
app: Ext::APP,
app_type: Datadog::Ext::AppTypes::WEB,
tracer: -> { get_option(:tracer) }
).onto(::GRPC)
end
def prepend_interceptor
::GRPC::InterceptionContext
.send(:prepend, Datadog::Contrib::GRPC::InterceptWithDatadog)
end
def get_option(option)
Datadog.configuration[:grpc].get_option(option)
end
# Implementation of deprecated Pin, which raises warnings when accessed.
# To be removed when support for Datadog::Pin with GRPC is removed.
class DeprecatedPin < Datadog::Pin
include Datadog::DeprecatedPin
DEPRECATION_WARNING = %(
Use of Datadog::Pin with GRPC is DEPRECATED.
Upgrade to the configuration API using the migration guide here:
https://github.com/DataDog/dd-trace-rb/releases/tag/v0.11.0).freeze
def service_name=(service_name)
Datadog.configuration[:grpc][:service_name] = service_name
end
def log_deprecation_warning(method_name)
do_once(method_name) do
Datadog.logger.warn("#{method_name}:#{DEPRECATION_WARNING}")
end
end
end
end
end
end
end
Version data entries
10 entries across 10 versions & 2 rubygems