registered

Documentation

Overview

Package to keep track of API Versions that can be registered and are enabled in api.Scheme.

Index

• Variables
• type APIRegistrationManager
  • func NewAPIRegistrationManager(kubeAPIVersions string) (*APIRegistrationManager, error)
  • func NewOrDie(kubeAPIVersions string) *APIRegistrationManager
  • func (m *APIRegistrationManager) AddThirdPartyAPIGroupVersions(gvs ...unversioned.GroupVersion) []unversioned.GroupVersion
  • func (m *APIRegistrationManager) AllPreferredGroupVersions() string
  • func (m *APIRegistrationManager) EnableVersions(versions ...unversioned.GroupVersion) error
  • func (m *APIRegistrationManager) EnabledVersions() []unversioned.GroupVersion
  • func (m *APIRegistrationManager) EnabledVersionsForGroup(group string) []unversioned.GroupVersion
  • func (m *APIRegistrationManager) Group(group string) (*apimachinery.GroupMeta, error)
  • func (m *APIRegistrationManager) GroupOrDie(group string) *apimachinery.GroupMeta
  • func (m *APIRegistrationManager) IsAllowedVersion(v unversioned.GroupVersion) bool
  • func (m *APIRegistrationManager) IsEnabledVersion(v unversioned.GroupVersion) bool
  • func (m *APIRegistrationManager) IsRegistered(group string) bool
  • func (m *APIRegistrationManager) IsRegisteredVersion(v unversioned.GroupVersion) bool
  • func (m *APIRegistrationManager) IsThirdPartyAPIGroupVersion(gv unversioned.GroupVersion) bool
  • func (m *APIRegistrationManager) RESTMapper(versionPatterns ...unversioned.GroupVersion) meta.RESTMapper
  • func (m *APIRegistrationManager) RegisterGroup(groupMeta apimachinery.GroupMeta) error
  • func (m *APIRegistrationManager) RegisterVersions(availableVersions []unversioned.GroupVersion)
  • func (m *APIRegistrationManager) RegisteredGroupVersions() []unversioned.GroupVersion
  • func (m *APIRegistrationManager) ValidateEnvRequestedVersions() []unversioned.GroupVersion

Variables

var (
	ValidateEnvRequestedVersions  = DefaultAPIRegistrationManager.ValidateEnvRequestedVersions
	AllPreferredGroupVersions     = DefaultAPIRegistrationManager.AllPreferredGroupVersions
	RESTMapper                    = DefaultAPIRegistrationManager.RESTMapper
	GroupOrDie                    = DefaultAPIRegistrationManager.GroupOrDie
	AddThirdPartyAPIGroupVersions = DefaultAPIRegistrationManager.AddThirdPartyAPIGroupVersions
	IsThirdPartyAPIGroupVersion   = DefaultAPIRegistrationManager.IsThirdPartyAPIGroupVersion
	RegisteredGroupVersions       = DefaultAPIRegistrationManager.RegisteredGroupVersions
	IsRegisteredVersion           = DefaultAPIRegistrationManager.IsRegisteredVersion
	IsRegistered                  = DefaultAPIRegistrationManager.IsRegistered
	Group                         = DefaultAPIRegistrationManager.Group
	EnabledVersionsForGroup       = DefaultAPIRegistrationManager.EnabledVersionsForGroup
	EnabledVersions               = DefaultAPIRegistrationManager.EnabledVersions
	IsEnabledVersion              = DefaultAPIRegistrationManager.IsEnabledVersion
	IsAllowedVersion              = DefaultAPIRegistrationManager.IsAllowedVersion
	EnableVersions                = DefaultAPIRegistrationManager.EnableVersions
	RegisterGroup                 = DefaultAPIRegistrationManager.RegisterGroup
	RegisterVersions              = DefaultAPIRegistrationManager.RegisterVersions
)

People are calling global functions. Let them continue to do that (for now).

var (
	DefaultAPIRegistrationManager = NewOrDie(os.Getenv("KUBE_API_VERSIONS"))
)

Types

type APIRegistrationManager

type APIRegistrationManager struct {
	// contains filtered or unexported fields
}

APIRegistrationManager

func NewAPIRegistrationManager

func NewAPIRegistrationManager(kubeAPIVersions string) (*APIRegistrationManager, error)

NewAPIRegistrationManager constructs a new manager. The argument ought to be the value of the KUBE_API_VERSIONS env var, or a value of this which you wish to test.

func NewOrDie

func NewOrDie(kubeAPIVersions string) *APIRegistrationManager

func (*APIRegistrationManager) AddThirdPartyAPIGroupVersions

func (m *APIRegistrationManager) AddThirdPartyAPIGroupVersions(gvs ...unversioned.GroupVersion) []unversioned.GroupVersion

AddThirdPartyAPIGroupVersions sets the list of third party versions, registers them in the API machinery and enables them. Skips GroupVersions that are already registered. Returns the list of GroupVersions that were skipped.

func (*APIRegistrationManager) AllPreferredGroupVersions

func (m *APIRegistrationManager) AllPreferredGroupVersions() string

AllPreferredGroupVersions returns the preferred versions of all registered groups in the form of "group1/version1,group2/version2,..."

func (*APIRegistrationManager) EnableVersions

func (m *APIRegistrationManager) EnableVersions(versions ...unversioned.GroupVersion) error

EnableVersions adds the versions for the given group to the list of enabled versions. Note that the caller should call RegisterGroup before calling this method. The caller of this function is responsible to add the versions to scheme and RESTMapper.

func (*APIRegistrationManager) EnabledVersions

func (m *APIRegistrationManager) EnabledVersions() []unversioned.GroupVersion

EnabledVersions returns all enabled versions. Groups are randomly ordered, but versions within groups are priority order from best to worst

func (*APIRegistrationManager) EnabledVersionsForGroup

func (m *APIRegistrationManager) EnabledVersionsForGroup(group string) []unversioned.GroupVersion

EnabledVersionsForGroup returns all enabled versions for a group in order of best to worst

func (*APIRegistrationManager) Group

func (m *APIRegistrationManager) Group(group string) (*apimachinery.GroupMeta, error)

Group returns the metadata of a group if the group is registered, otherwise an error is returned.

func (*APIRegistrationManager) GroupOrDie

func (m *APIRegistrationManager) GroupOrDie(group string) *apimachinery.GroupMeta

TODO: This is an expedient function, because we don't check if a Group is supported throughout the code base. We will abandon this function and checking the error returned by the Group() function.

func (*APIRegistrationManager) IsAllowedVersion

func (m *APIRegistrationManager) IsAllowedVersion(v unversioned.GroupVersion) bool

IsAllowedVersion returns if the version is allowed by the KUBE_API_VERSIONS environment variable. If the environment variable is empty, then it always returns true.

func (*APIRegistrationManager) IsEnabledVersion

func (m *APIRegistrationManager) IsEnabledVersion(v unversioned.GroupVersion) bool

IsEnabledVersion returns if a version is enabled.

func (*APIRegistrationManager) IsRegistered

func (m *APIRegistrationManager) IsRegistered(group string) bool

IsRegistered takes a string and determines if it's one of the registered groups

func (*APIRegistrationManager) IsRegisteredVersion

func (m *APIRegistrationManager) IsRegisteredVersion(v unversioned.GroupVersion) bool

IsRegisteredVersion returns if a version is registered.

func (*APIRegistrationManager) IsThirdPartyAPIGroupVersion

func (m *APIRegistrationManager) IsThirdPartyAPIGroupVersion(gv unversioned.GroupVersion) bool

IsThirdPartyAPIGroupVersion returns true if the api version is a user-registered group/version.

func (*APIRegistrationManager) RESTMapper

func (m *APIRegistrationManager) RESTMapper(versionPatterns ...unversioned.GroupVersion) meta.RESTMapper

RESTMapper returns a union RESTMapper of all known types with priorities chosen in the following order:

1. if KUBE_API_VERSIONS is specified, then KUBE_API_VERSIONS in order, OR
1. legacy kube group preferred version, extensions preferred version, metrics perferred version, legacy kube any version, extensions any version, metrics any version, all other groups alphabetical preferred version, all other groups alphabetical.

func (*APIRegistrationManager) RegisterGroup

func (m *APIRegistrationManager) RegisterGroup(groupMeta apimachinery.GroupMeta) error

RegisterGroup adds the given group to the list of registered groups.

func (*APIRegistrationManager) RegisterVersions

func (m *APIRegistrationManager) RegisterVersions(availableVersions []unversioned.GroupVersion)

RegisterVersions adds the given group versions to the list of registered group versions.

func (*APIRegistrationManager) RegisteredGroupVersions

func (m *APIRegistrationManager) RegisteredGroupVersions() []unversioned.GroupVersion

RegisteredGroupVersions returns all registered group versions.

func (*APIRegistrationManager) ValidateEnvRequestedVersions

func (m *APIRegistrationManager) ValidateEnvRequestedVersions() []unversioned.GroupVersion

ValidateEnvRequestedVersions returns a list of versions that are requested in the KUBE_API_VERSIONS environment variable, but not enabled.