kubernetes/staging/src/k8s.io/apiextensions-apiserver/pkg/controller/establish/establishing_controller.go

type EstablishingController …

// NewEstablishingController creates new EstablishingController.
func NewEstablishingController(crdInformer informers.CustomResourceDefinitionInformer,
	crdClient client.CustomResourceDefinitionsGetter) *EstablishingController { … }

// QueueCRD adds CRD into the establishing queue.
func (ec *EstablishingController) QueueCRD(key string, timeout time.Duration) { … }

// Run starts the EstablishingController.
func (ec *EstablishingController) Run(stopCh <-chan struct{ … }

func (ec *EstablishingController) runWorker() { … }

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

// sync is used to turn CRDs into the Established state.
func (ec *EstablishingController) sync(key string) error { … }