Sha256: 8536643ca0fcfa25c84da8609a937e99896ab2464900fee935826d3d534e24ef
Contents?: true
Size: 1.51 KB
Versions: 8
Compression:
Stored size: 1.51 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, 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: host, port: port, code: response.code, reason: response.message })
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
8 entries across 8 versions & 1 rubygems