kubernetes/staging/src/k8s.io/kube-aggregator/pkg/controllers/status/local/local_available_controller.go

type AvailableConditionController …

// New returns a new local availability AvailableConditionController.
func New(
	apiServiceInformer informers.APIServiceInformer,
	apiServiceClient apiregistrationclient.APIServicesGetter,
	metrics *availabilitymetrics.Metrics,
) (*AvailableConditionController, error) { … }

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

// updateAPIServiceStatus only issues an update if a change is detected.  We have a tight resync loop to quickly detect dead
// apiservices. Doing that means we don't want to quickly issue no-op updates.
func (c *AvailableConditionController) updateAPIServiceStatus(originalAPIService, newAPIService *apiregistrationv1.APIService) (*apiregistrationv1.APIService, error) { … }

// Run starts the AvailableConditionController loop which manages the availability condition of API services.
func (c *AvailableConditionController) Run(workers int, stopCh <-chan struct{ … }

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

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

func (c *AvailableConditionController) addAPIService(obj interface{ … }

func (c *AvailableConditionController) updateAPIService(oldObj, _ interface{ … }

func (c *AvailableConditionController) deleteAPIService(obj interface{ … }