Class: Datadog::Core::Transport::HTTP::Builder

Inherits:
Object
  • Object
show all
Defined in:
lib/datadog/core/transport/http/builder.rb

Overview

Builds new instances of Transport::HTTP::Client

Defined Under Namespace

Classes: NoAdapterForApiError, NoApisError, NoDefaultApiError, UnknownAdapterError, UnknownApiError

Constant Summary collapse

REGISTRY = 
Datadog::Core::Transport::HTTP::Adapters::Registry.new

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(api_instance_class:, logger: Datadog.logger) {|_self| ... } ⇒ Builder

Returns a new instance of Builder.

Yields:

  • (_self)

Yield Parameters:



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
 
# File 'lib/datadog/core/transport/http/builder.rb', line 24

def initialize(api_instance_class:, logger: Datadog.logger)
  # Global settings
  @default_adapter = nil
  @default_headers = {}

  # Client settings
  @apis = Datadog::Core::Transport::HTTP::API::Map.new
  @default_api = nil

  # API settings
  @api_options = {}

  @api_instance_class = api_instance_class
  @logger = logger

  yield(self) if block_given?
end

Instance Attribute Details

#api_instance_class ⇒ Object (readonly)

Returns the value of attribute api_instance_class.



15
16
17
 
# File 'lib/datadog/core/transport/http/builder.rb', line 15

def api_instance_class
  @api_instance_class
end

#api_options ⇒ Object (readonly)

Returns the value of attribute api_options.



15
16
17
 
# File 'lib/datadog/core/transport/http/builder.rb', line 15

def api_options
  @api_options
end

#apis ⇒ Object (readonly)

Returns the value of attribute apis.



15
16
17
 
# File 'lib/datadog/core/transport/http/builder.rb', line 15

def apis
  @apis
end

#default_adapter ⇒ Object (readonly)

Returns the value of attribute default_adapter.



15
16
17
 
# File 'lib/datadog/core/transport/http/builder.rb', line 15

def default_adapter
  @default_adapter
end

#default_api ⇒ Object

Returns the value of attribute default_api.



15
16
17
 
# File 'lib/datadog/core/transport/http/builder.rb', line 15

def default_api
  @default_api
end

#default_headers ⇒ Object (readonly)

Returns the value of attribute default_headers.



15
16
17
 
# File 'lib/datadog/core/transport/http/builder.rb', line 15

def default_headers
  @default_headers
end

#logger ⇒ Object (readonly)

Returns the value of attribute logger.



15
16
17
 
# File 'lib/datadog/core/transport/http/builder.rb', line 15

def logger
  @logger
end

Instance Method Details

#adapter(config, *args, **kwargs) ⇒ Object 



42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
 
# File 'lib/datadog/core/transport/http/builder.rb', line 42

def adapter(config, *args, **kwargs)
  @default_adapter = case config
                     when Core::Configuration::AgentSettingsResolver::AgentSettings
                       registry_klass = REGISTRY.get(config.adapter)
                       raise UnknownAdapterError, config.adapter if registry_klass.nil?

                       registry_klass.build(config)
                     when Symbol
                       registry_klass = REGISTRY.get(config)
                       raise UnknownAdapterError, config if registry_klass.nil?

                       registry_klass.new(*args, **kwargs)
                     else
                       config
                     end
end

#api(key, spec, options = {}) ⇒ Object

Adds a new API to the client Valid options:

- :adapter
- :default
- :fallback
- :headers



69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/datadog/core/transport/http/builder.rb', line 69

def api(key, spec, options = {})
  options = options.dup

  # Copy spec into API map
  @apis[key] = spec

  # Apply as default API, if specified to do so.
  @default_api = key if options.delete(:default) || @default_api.nil?

  # Save all other settings for initialization
  (@api_options[key] ||= {}).merge!(options)
end

#headers(values = {}) ⇒ Object 



59
60
61
 
# File 'lib/datadog/core/transport/http/builder.rb', line 59

def headers(values = {})
  @default_headers.merge!(values)
end

#to_api_instances ⇒ Object

Raises:



94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
 
# File 'lib/datadog/core/transport/http/builder.rb', line 94

def to_api_instances
  raise NoApisError if @apis.empty?

  @apis.inject(Datadog::Core::Transport::HTTP::API::Map.new) do |instances, (key, spec)|
    instances.tap do
      api_options = @api_options[key].dup

      # Resolve the adapter to use for this API
      adapter = api_options.delete(:adapter) || @default_adapter
      raise NoAdapterForApiError, key if adapter.nil?

      # Resolve fallback and merge headers
      fallback = api_options.delete(:fallback)
      api_options[:headers] = @default_headers.merge((api_options[:headers] || {}))

      # Add API::Instance with all settings
      instances[key] = api_instance_class.new(
        spec,
        adapter,
        api_options
      )

      # Configure fallback, if provided.
      instances.with_fallbacks(key => fallback) unless fallback.nil?
    end
  end
end

#to_transport(klass) ⇒ Object

Raises:



88
89
90
91
92
 
# File 'lib/datadog/core/transport/http/builder.rb', line 88

def to_transport(klass)
  raise NoDefaultApiError if @default_api.nil?

  klass.new(to_api_instances, @default_api, logger: logger)
end