kubernetes/pkg/controlplane/controller/crdregistration/crdregistration_controller.go

type AutoAPIServiceRegistration …

type crdRegistrationController …

// NewCRDRegistrationController returns a controller which will register CRD GroupVersions with the auto APIService registration
// controller so they automatically stay in sync.
func NewCRDRegistrationController(crdinformer crdinformers.CustomResourceDefinitionInformer, apiServiceRegistration AutoAPIServiceRegistration) *crdRegistrationController { … }

func (c *crdRegistrationController) Run(workers int, stopCh <-chan struct{ … }

// WaitForInitialSync blocks until the initial set of CRD resources has been processed
func (c *crdRegistrationController) WaitForInitialSync() { … }

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

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

func (c *crdRegistrationController) enqueueCRD(crd *apiextensionsv1.CustomResourceDefinition) { … }

func (c *crdRegistrationController) handleVersionUpdate(groupVersion schema.GroupVersion) error { … }