Sha256: e361539daba3b7333ac2202f6bb7fa46e1266330c0e1284467d2fcc0d22f9e0d
Contents?: true
Size: 1.52 KB
Versions: 4
Compression:
Stored size: 1.52 KB
Contents
class Puppet::HTTP::Resolver::ServerList < Puppet::HTTP::Resolver
def initialize(client, server_list_setting:, default_port:, services: )
@client = client
@server_list_setting = server_list_setting
@default_port = default_port
@services = services
end
def resolve(session, name, ssl_context: nil)
if @services.include?(name)
@server_list_setting.value.each do |server|
host = server[0]
port = server[1] || @default_port
uri = URI("https://#{host}:#{port}/status/v1/simple/master")
if get_success?(uri, session, ssl_context: ssl_context)
return Puppet::HTTP::Service.create_service(@client, session, name, host, port)
end
end
raise Puppet::Error, _("Could not select a functional puppet master from server_list: '%{server_list}'") % { server_list: @server_list_setting.print(@server_list_setting.value) }
else
return nil
end
end
def get_success?(uri, session, ssl_context: nil)
response = @client.get(uri, ssl_context: ssl_context)
return true if response.success?
Puppet.debug(_("Puppet server %{host}:%{port} is unavailable: %{code} %{reason}") %
{ host: uri.host, port: uri.port, code: response.code, reason: response.reason })
return false
rescue => detail
session.add_exception(detail)
#TRANSLATORS 'server_list' is the name of a setting and should not be translated
Puppet.debug _("Unable to connect to server from server_list setting: %{detail}") % {detail: detail}
return false
end
end
Version data entries
4 entries across 4 versions & 1 rubygems