kubernetes/staging/src/k8s.io/kube-aggregator/pkg/apiserver/handler_discovery.go

var APIRegistrationGroupVersion …

var APIRegistrationGroupPriority …

var v2Beta1GVK …

var v2GVK …

type DiscoveryAggregationController …

type discoveryManager …

type serviceKey …

// Human-readable String representation used for logs
func (s serviceKey) String() string { … }

func newServiceKey(service apiregistrationv1.ServiceReference) serviceKey { … }

type cachedResult …

type groupVersionInfo …

var _ …

func NewDiscoveryManager(
	target discoveryendpoint.ResourceManager,
) DiscoveryAggregationController { … }

// Returns discovery data for the given apiservice.
// Caches the result.
// Returns the cached result if it is retrieved after the apiservice was last
// marked dirty
// If there was an error in fetching, returns the stale cached result if it exists,
// and a non-nil error
// If the result is current, returns nil error and non-nil result
func (dm *discoveryManager) fetchFreshDiscoveryForService(gv metav1.GroupVersion, info groupVersionInfo) (*cachedResult, error) { … }

// Try to sync a single APIService.
func (dm *discoveryManager) syncAPIService(apiServiceName string) error { … }

func (dm *discoveryManager) getAPIServiceKeys() []string { … }

// Spawns a goroutine which waits for added/updated apiservices and updates
// the discovery document accordingly
func (dm *discoveryManager) Run(stopCh <-chan struct{ … }

// Takes a snapshot of all currently used services by known APIServices and
// purges the cache entries of those not present in the snapshot.
func (dm *discoveryManager) removeUnusedServices() { … }

// Adds an APIService to be tracked by the discovery manager. If the APIService
// is already known
func (dm *discoveryManager) AddAPIService(apiService *apiregistrationv1.APIService, handler http.Handler) { … }

func (dm *discoveryManager) RemoveAPIService(apiServiceName string) { … }

func (dm *discoveryManager) getCacheEntryForService(key serviceKey) (cachedResult, bool) { … }

func (dm *discoveryManager) setCacheEntryForService(key serviceKey, result cachedResult) { … }

func (dm *discoveryManager) getInfoForAPIService(name string) (groupVersionInfo, bool) { … }

func (dm *discoveryManager) setInfoForAPIService(name string, result *groupVersionInfo) (oldValueIfExisted *groupVersionInfo) { … }