kubernetes/staging/src/k8s.io/apiextensions-apiserver/pkg/controller/nonstructuralschema/nonstructuralschema_controller.go

type ConditionController …

// NewConditionController constructs a non-structural schema condition controller.
func NewConditionController(
	crdInformer informers.CustomResourceDefinitionInformer,
	crdClient client.CustomResourceDefinitionsGetter,
) *ConditionController { … }

func calculateCondition(in *apiextensionsv1.CustomResourceDefinition) *apiextensionsv1.CustomResourceDefinitionCondition { … }

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

// Run starts the controller.
func (c *ConditionController) Run(workers int, stopCh <-chan struct{ … }

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

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

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

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

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

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