kubernetes/staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go

type DiscoveryController …

func NewDiscoveryController(
	crdInformer informers.CustomResourceDefinitionInformer,
	versionHandler *versionDiscoveryHandler,
	groupHandler *groupDiscoveryHandler,
	resourceManager discoveryendpoint.ResourceManager,
) *DiscoveryController { … }

func (c *DiscoveryController) sync(version schema.GroupVersion) error { … }

func sortGroupDiscoveryByKubeAwareVersion(gd []metav1.GroupVersionForDiscovery) { … }

func (c *DiscoveryController) Run(stopCh <-chan struct{ … }

func (c *DiscoveryController) runWorker() { … }

// processNextWorkItem deals with one key off the queue.  It returns false when it's time to quit.
func (c *DiscoveryController) processNextWorkItem() bool { … }

func (c *DiscoveryController) enqueue(obj *apiextensionsv1.CustomResourceDefinition) { … }

func (c *DiscoveryController) addCustomResourceDefinition(obj interface{ … }

func (c *DiscoveryController) updateCustomResourceDefinition(oldObj, newObj interface{ … }

func (c *DiscoveryController) deleteCustomResourceDefinition(obj interface{ … }