Sha256: 15b21dc261d568f6862fb2c4a616740d687a105ceb958fca613ffb9d4d1d4811
Contents?: true
Size: 1.63 KB
Versions: 8
Compression:
Stored size: 1.63 KB
Contents
class Puppet::HTTP::Session
Route = Struct.new(:service_class, :api, :server_setting, :port_setting)
ROUTES = {
ca: Route.new(Puppet::HTTP::Service::Ca, '/puppet-ca/v1', :ca_server, :ca_port),
}.freeze
def initialize(client, resolvers)
@client = client
@resolvers = resolvers
@resolved_services = {}
end
def route_to(name, ssl_context: nil)
route = ROUTES[name]
raise ArgumentError, "Unknown service #{name}" unless route
cached = @resolved_services[name]
return cached if cached
errors = []
@resolvers.each do |resolver|
Puppet.debug("Resolving service '#{name}' using #{resolver.class}")
resolver.resolve(self, name) do |service|
begin
service.connect(ssl_context: ssl_context)
@resolved_services[name] = service
Puppet.debug("Resolved service '#{name}' to #{service.url}")
return service
rescue Puppet::HTTP::ConnectionError => e
errors << e
Puppet.debug("Connection to #{service.url} failed, trying next route: #{e.message}")
end
end
end
errors.each { |e| Puppet.log_exception(e) }
raise Puppet::HTTP::RouteError, "No more routes to #{name}"
end
def create_service(name, server = nil, port = nil)
route = ROUTES[name]
raise ArgumentError, "Unknown service #{name}" unless route
server ||= Puppet[route.server_setting]
port ||= Puppet[route.port_setting]
url = URI::HTTPS.build(host: server,
port: port,
path: route.api
).freeze
route.service_class.new(@client, url)
end
end
Version data entries
8 entries across 8 versions & 1 rubygems