Sha256: ce357bb0995da751d819d55b6e78f297a737902f179bd5b1527bd8d73d39edc8
Contents?: true
Size: 1.91 KB
Versions: 7
Compression:
Stored size: 1.91 KB
Contents
# typed: false
require_relative '../../metadata/ext'
require_relative '../analytics'
require_relative 'ext'
require_relative 'quantize'
module Datadog
module Tracing
module Contrib
module Dalli
# Instruments every interaction with the memcached server
module Instrumentation
def self.included(base)
base.prepend(InstanceMethods)
end
# InstanceMethods - implementing instrumentation
module InstanceMethods
def request(op, *args)
Tracing.trace(Ext::SPAN_COMMAND) do |span|
span.resource = op.to_s.upcase
span.service = datadog_configuration[:service_name]
span.span_type = Ext::SPAN_TYPE_COMMAND
span.set_tag(Tracing::Metadata::Ext::TAG_COMPONENT, Ext::TAG_COMPONENT)
span.set_tag(Tracing::Metadata::Ext::TAG_OPERATION, Ext::TAG_OPERATION_COMMAND)
# Tag as an external peer service
span.set_tag(Tracing::Metadata::Ext::TAG_PEER_SERVICE, span.service)
span.set_tag(Tracing::Metadata::Ext::TAG_PEER_HOSTNAME, hostname)
# Set analytics sample rate
if Contrib::Analytics.enabled?(datadog_configuration[:analytics_enabled])
Contrib::Analytics.set_sample_rate(span, datadog_configuration[:analytics_sample_rate])
end
span.set_tag(Tracing::Metadata::Ext::NET::TAG_TARGET_HOST, hostname)
span.set_tag(Tracing::Metadata::Ext::NET::TAG_TARGET_PORT, port)
cmd = Quantize.format_command(op, args)
span.set_tag(Ext::TAG_COMMAND, cmd)
super
end
end
private
def datadog_configuration
Datadog.configuration.tracing[:dalli, "#{hostname}:#{port}"]
end
end
end
end
end
end
end
Version data entries
7 entries across 7 versions & 1 rubygems