Sha256: b12f66437efbd6b0723717730352c9857a07f6e87d111627f33baf26fafb2c73
Contents?: true
Size: 1.89 KB
Versions: 8
Compression:
Stored size: 1.89 KB
Contents
# frozen_string_literal: true
require_relative 'transport/http'
module Datadog
module Core
module Remote
# Endpoint negotiation
class Negotiation
def initialize(_settings, agent_settings)
transport_options = {}
transport_options[:agent_settings] = agent_settings if agent_settings
@transport_root = Datadog::Core::Remote::Transport::HTTP.root(**transport_options.dup)
@logged = {}
end
def endpoint?(path)
res = @transport_root.send_info
if res.internal_error? && network_error?(res.error)
unless @logged[:agent_unreachable]
Datadog.logger.error { "agent unreachable: cannot negotiate #{path}" }
@logged[:agent_unreachable] = true
end
return false
end
if res.not_found?
unless @logged[:no_info_endpoint]
Datadog.logger.error { "agent reachable but has no /info endpoint: cannot negotiate #{path}" }
@logged[:no_info_endpoint] = true
end
return false
end
unless res.ok?
unless @logged[:unexpected_response]
Datadog.logger.error { "agent reachable but unexpected response: cannot negotiate #{path}" }
@logged[:unexpected_response] = true
end
return false
end
unless res.endpoints.include?(path)
unless @logged[:no_config_endpoint]
Datadog.logger.error { "agent reachable but does not report #{path}" }
@logged[:no_config_endpoint] = true
end
return false
end
Datadog.logger.debug { "agent reachable and reports #{path}" }
true
end
private
def network_error?(error)
error.is_a?(Errno::ECONNREFUSED)
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems