kubernetes/staging/src/k8s.io/apiserver/pkg/endpoints/discovery/aggregated/handler.go

type Source …

const AggregatorSource …

const BuiltinSource …

const CRDSource …

type ResourceManager …

type resourceManager …

func (rm resourceManager) AddGroupVersion(groupName string, value apidiscoveryv2.APIVersionDiscovery) { … }

func (rm resourceManager) SetGroupVersionPriority(gv metav1.GroupVersion, grouppriority, versionpriority int) { … }

func (rm resourceManager) RemoveGroup(groupName string) { … }

func (rm resourceManager) RemoveGroupVersion(gv metav1.GroupVersion) { … }

func (rm resourceManager) SetGroups(groups []apidiscoveryv2.APIGroupDiscovery) { … }

func (rm resourceManager) WithSource(source Source) ResourceManager { … }

type groupKey …

type groupVersionKey …

type resourceDiscoveryManager …

type priorityInfo …

func NewResourceManager(path string) ResourceManager { … }

func (rdm *resourceDiscoveryManager) SetGroupVersionPriority(source Source, gv metav1.GroupVersion, groupPriorityMinimum, versionPriority int) { … }

func (rdm *resourceDiscoveryManager) SetGroups(source Source, groups []apidiscoveryv2.APIGroupDiscovery) { … }

func (rdm *resourceDiscoveryManager) AddGroupVersion(source Source, groupName string, value apidiscoveryv2.APIVersionDiscovery) { … }

func (rdm *resourceDiscoveryManager) addGroupVersionLocked(source Source, groupName string, value apidiscoveryv2.APIVersionDiscovery) { … }

func (rdm *resourceDiscoveryManager) RemoveGroupVersion(source Source, apiGroup metav1.GroupVersion) { … }

func (rdm *resourceDiscoveryManager) RemoveGroup(source Source, groupName string) { … }

// Prepares the api group list for serving by converting them from map into
// list and sorting them according to insertion order
func (rdm *resourceDiscoveryManager) calculateAPIGroupsLocked() []apidiscoveryv2.APIGroupDiscovery { … }

// Fetches from cache if it exists. If cache is empty, create it.
func (rdm *resourceDiscoveryManager) fetchFromCache() *cachedGroupList { … }

type cachedGroupList …

func (rdm *resourceDiscoveryManager) ServeHTTP(resp http.ResponseWriter, req *http.Request) { … }

func (rdm *resourceDiscoveryManager) serveHTTP(resp http.ResponseWriter, req *http.Request) { … }