latest.go

package latest

import (
	"strings"
	"sync"

	"k8s.io/kubernetes/pkg/api"
	"k8s.io/kubernetes/pkg/api/unversioned"
)

// HACK TO ELIMINATE CYCLES UNTIL WE KILL THIS PACKAGE

// Version is the string that represents the current external default version.
var Version = unversioned.GroupVersion{Group: "", Version: "v1"}

// OldestVersion is the string that represents the oldest server version supported,
// for client code that wants to hardcode the lowest common denominator.
var OldestVersion = unversioned.GroupVersion{Group: "", Version: "v1"}

// Versions is the list of versions that are recognized in code. The order provided
// may be assumed to be most preferred to least preferred, and clients may
// choose to prefer the earlier items in the list over the latter items when presented
// with a set of versions to choose.
var Versions = []unversioned.GroupVersion{{Group: "", Version: "v1"}}

// originTypes are the hardcoded types defined by the OpenShift API.
var originTypes map[unversioned.GroupVersionKind]bool

// originTypesLock allows lazying initialization of originTypes to allow initializers to run before
// loading the map.  It means that initializers have to know ahead of time where their type is from,
// but that is not onerous
var originTypesLock sync.Once

// OriginKind returns true if OpenShift owns the GroupVersionKind.
func OriginKind(gvk unversioned.GroupVersionKind) bool {
	return getOrCreateOriginKinds()[gvk]
}

// IsKindInAnyOriginGroup returns true if OpenShift owns the kind described in any apiVersion.
// TODO: this may not work once we divide builds/deployments/images into their own API groups
func IsKindInAnyOriginGroup(kind string) bool {
	for _, version := range Versions {
		if OriginKind(version.WithKind(kind)) {
			return true
		}
	}

	return false
}

func getOrCreateOriginKinds() map[unversioned.GroupVersionKind]bool {
	if originTypes == nil {
		originTypesLock.Do(func() {
			newOriginTypes := map[unversioned.GroupVersionKind]bool{}

			// enumerate all supported versions, get the kinds, and register with the mapper how to address our resources
			for _, version := range Versions {
				for kind, t := range api.Scheme.KnownTypes(version) {
					if !strings.Contains(t.PkgPath(), "github.com/openshift/origin") || strings.Contains(t.PkgPath(), "github.com/openshift/origin/vendor/") {
						continue
					}
					gvk := version.WithKind(kind)
					newOriginTypes[gvk] = true
				}
			}
			originTypes = newOriginTypes
		})

		return originTypes
	}

	return originTypes
}