kubernetes/staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go

type NamingConditionController …

func NewNamingConditionController(
	crdInformer informers.CustomResourceDefinitionInformer,
	crdClient client.CustomResourceDefinitionsGetter,
) *NamingConditionController { … }

func (c *NamingConditionController) getAcceptedNamesForGroup(group string) (allResources sets.String, allKinds sets.String) { … }

func (c *NamingConditionController) calculateNamesAndConditions(in *apiextensionsv1.CustomResourceDefinition) (apiextensionsv1.CustomResourceDefinitionNames, apiextensionsv1.CustomResourceDefinitionCondition, apiextensionsv1.CustomResourceDefinitionCondition) { … }

func equalToAcceptedOrFresh(requestedName, acceptedName string, usedNames sets.String) error { … }

func (c *NamingConditionController) sync(key string) error { … }

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

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

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

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

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

func (c *NamingConditionController) updateCustomResourceDefinition(obj, _ interface{ … }

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

func (c *NamingConditionController) requeueAllOtherGroupCRDs(name string) error { … }