Sha256: 6e8d30d261f0c43a18bf1d92a75de26c1cfe4bf083df43e92dc254818fab5d5c
Contents?: true
Size: 1.88 KB
Versions: 24
Compression:
Stored size: 1.88 KB
Contents
require_relative 'configuration/proxy'
require_relative 'configuration/resolver'
require_relative 'configuration/pin_setup'
module Datadog
# Configuration provides a unique access point for configurations
class Configuration
InvalidIntegrationError = Class.new(StandardError)
def initialize(options = {})
@registry = options.fetch(:registry) { Datadog.registry }
@wrapped_registry = {}
end
def [](integration_name, configuration_name = :default)
integration = fetch_integration(integration_name)
if integration.class <= Datadog::Contrib::Integration
integration.configuration(configuration_name)
else
@wrapped_registry[integration_name] ||= Proxy.new(integration)
end
end
def use(integration_name, options = {}, &block)
integration = fetch_integration(integration_name)
if integration.class <= Datadog::Contrib::Integration
configuration_name = options[:describes] || :default
filtered_options = options.reject { |k, _v| k == :describes }
integration.configure(configuration_name, filtered_options, &block)
else
settings = Proxy.new(integration)
integration.sorted_options.each do |name|
settings[name] = options.fetch(name, settings[name])
end
end
integration.patch if integration.respond_to?(:patch)
end
def tracer(options = {})
instance = options.fetch(:instance, Datadog.tracer)
instance.configure(options)
instance.class.log = options[:log] if options[:log]
instance.set_tags(options[:tags]) if options[:tags]
instance.set_tags(env: options[:env]) if options[:env]
instance.class.debug_logging = options.fetch(:debug, false)
end
private
def fetch_integration(name)
@registry[name] ||
raise(InvalidIntegrationError, "'#{name}' is not a valid integration.")
end
end
end
Version data entries
24 entries across 24 versions & 1 rubygems