const AutoRegisterManagedLabel … const manageOnStart … const manageContinuously … type AutoAPIServiceRegistration … type autoRegisterController … // NewAutoRegisterController creates a new autoRegisterController. func NewAutoRegisterController(apiServiceInformer informers.APIServiceInformer, apiServiceClient apiregistrationclient.APIServicesGetter) *autoRegisterController { … } // Run starts the autoregister controller in a loop which syncs API services until stopCh is closed. func (c *autoRegisterController) Run(workers int, stopCh <-chan struct{ … } func (c *autoRegisterController) runWorker() { … } // processNextWorkItem deals with one key off the queue. It returns false when it's time to quit. func (c *autoRegisterController) processNextWorkItem() bool { … } // checkAPIService syncs the current APIService against a list of desired APIService objects // // | A. desired: not found | B. desired: sync on start | C. desired: sync always // ------------------------------------------------|-----------------------|---------------------------|------------------------ // 1. current: lookup error | error | error | error // 2. current: not found | - | create once | create // 3. current: no sync | - | - | - // 4. current: sync on start, not present at start | - | - | - // 5. current: sync on start, present at start | delete once | update once | update once // 6. current: sync always | delete | update once | update func (c *autoRegisterController) checkAPIService(name string) (err error) { … } // GetAPIServiceToSync gets a single API service to sync. func (c *autoRegisterController) GetAPIServiceToSync(name string) *v1.APIService { … } // AddAPIServiceToSyncOnStart registers an API service to sync only when the controller starts. func (c *autoRegisterController) AddAPIServiceToSyncOnStart(in *v1.APIService) { … } // AddAPIServiceToSync registers an API service to sync continuously. func (c *autoRegisterController) AddAPIServiceToSync(in *v1.APIService) { … } func (c *autoRegisterController) addAPIServiceToSync(in *v1.APIService, syncType string) { … } // RemoveAPIServiceToSync deletes a registered APIService. func (c *autoRegisterController) RemoveAPIServiceToSync(name string) { … } func (c *autoRegisterController) hasSyncedSuccessfully(name string) bool { … } func (c *autoRegisterController) setSyncedSuccessfully(name string) { … } func automanagedType(service *v1.APIService) string { … } func isAutomanagedOnStart(service *v1.APIService) bool { … } func isAutomanaged(service *v1.APIService) bool { … }
Codebase Browser
kubernetes