kubernetes/staging/src/k8s.io/kube-aggregator/pkg/controllers/status/remote/remote_available_controller.go

type certKeyFunc …

type ServiceResolver …

type AvailableConditionController …

// New returns a new remote APIService AvailableConditionController.
func New(
	apiServiceInformer informers.APIServiceInformer,
	serviceInformer v1informers.ServiceInformer,
	endpointsInformer v1informers.EndpointsInformer,
	apiServiceClient apiregistrationclient.APIServicesGetter,
	proxyTransportDial *transport.DialHolder,
	proxyCurrentCertKeyContent certKeyFunc,
	serviceResolver ServiceResolver,
	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, newObj interface{ … }

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

func (c *AvailableConditionController) getAPIServicesFor(obj runtime.Object) []string { … }

// if the service/endpoint handler wins the race against the cache rebuilding, it may queue a no-longer-relevant apiservice
// (which will get processed an extra time - this doesn't matter),
// and miss a newly relevant apiservice (which will get queued by the apiservice handler)
func (c *AvailableConditionController) rebuildAPIServiceCache() { … }

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

func (c *AvailableConditionController) updateService(obj, _ interface{ … }

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

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

func (c *AvailableConditionController) updateEndpoints(obj, _ interface{ … }

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