registry/service_v2.go
39f2f15a
 package registry
 
 import (
 	"fmt"
 	"strings"
 
2655954c
 	"github.com/docker/docker/reference"
8e034802
 	"github.com/docker/go-connections/tlsconfig"
39f2f15a
 )
 
4352da78
 func (s *Service) lookupV2Endpoints(repoName reference.Named) (endpoints []APIEndpoint, err error) {
39f2f15a
 	var cfg = tlsconfig.ServerDefault
 	tlsConfig := &cfg
ffded61d
 	nameString := repoName.FullName()
4352da78
 	if strings.HasPrefix(nameString, DefaultNamespace+"/") {
39f2f15a
 		// v2 mirrors
 		for _, mirror := range s.Config.Mirrors {
 			mirrorTLSConfig, err := s.tlsConfigForMirror(mirror)
 			if err != nil {
 				return nil, err
 			}
 			endpoints = append(endpoints, APIEndpoint{
 				URL: mirror,
 				// guess mirrors are v2
 				Version:      APIVersion2,
 				Mirror:       true,
 				TrimHostname: true,
 				TLSConfig:    mirrorTLSConfig,
 			})
 		}
 		// v2 registry
 		endpoints = append(endpoints, APIEndpoint{
 			URL:          DefaultV2Registry,
 			Version:      APIVersion2,
 			Official:     true,
 			TrimHostname: true,
 			TLSConfig:    tlsConfig,
 		})
 
 		return endpoints, nil
 	}
 
4352da78
 	slashIndex := strings.IndexRune(nameString, '/')
39f2f15a
 	if slashIndex <= 0 {
4352da78
 		return nil, fmt.Errorf("invalid repo name: missing '/':  %s", nameString)
39f2f15a
 	}
4352da78
 	hostname := nameString[:slashIndex]
39f2f15a
 
 	tlsConfig, err = s.TLSConfig(hostname)
 	if err != nil {
 		return nil, err
 	}
 
 	endpoints = []APIEndpoint{
 		{
a57478d6
 			URL:          "https://" + hostname,
 			Version:      APIVersion2,
 			TrimHostname: true,
 			TLSConfig:    tlsConfig,
39f2f15a
 		},
 	}
 
 	if tlsConfig.InsecureSkipVerify {
 		endpoints = append(endpoints, APIEndpoint{
 			URL:          "http://" + hostname,
 			Version:      APIVersion2,
 			TrimHostname: true,
 			// used to check if supposed to be secure via InsecureSkipVerify
a57478d6
 			TLSConfig: tlsConfig,
39f2f15a
 		})
 	}
 
 	return endpoints, nil
 }