Sha256: 09f1ad27d0fef1026e700321908d9261ccd736be34b3fb762d04b4293164c2c4
Contents?: true
Size: 1.8 KB
Versions: 4
Compression:
Stored size: 1.8 KB
Contents
require 'katello/util/data' module Katello module Resources require 'rest_client' module Registry class Proxy def self.logger ::Foreman::Logging.logger('katello/registry_proxy') end def self.get(path, headers = {:accept => :json}) logger.debug "Sending GET request to Registry: #{path}" client = RegistryResource.load_class.rest_client(Net::HTTP::Get, :get, path) client.get(headers) end end class RegistryResource < HttpResource class << self def load_class container_config = SETTINGS.dig(:katello, :container_image_registry) registry_url = nil pulp_master = ::SmartProxy.pulp_master # Pulp 3 has its own registry if pulp_master && pulp_master.pulp3_repository_type_support?(::Katello::Repository::DOCKER_TYPE) registry_url = pulp_master.setting('Pulp3', 'content_app_url') # Assume the registry uses the same CA as the Smart Proxy ca_cert_file = Setting[:ssl_ca_file] elsif container_config registry_url = container_config[:crane_url] ca_cert_file = container_config[:registry_ca_cert_file] end fail Errors::ContainerRegistryNotConfigured unless registry_url uri = URI.parse(registry_url) self.prefix = uri.path self.site = "#{uri.scheme}://#{uri.host}:#{uri.port}" self.ca_cert_file = ca_cert_file self end def process_response(response) debug_level = response.code >= 400 ? :error : :debug logger.send(debug_level, "Registry request returned with code #{response.code}") super end end end end end end
Version data entries
4 entries across 4 versions & 1 rubygems