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{}