type certKeyFunc …
type ServiceResolver …
type 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 { … }
func (c *AvailableConditionController) updateAPIServiceStatus(originalAPIService, newAPIService *apiregistrationv1.APIService) (*apiregistrationv1.APIService, error) { … }
func (c *AvailableConditionController) Run(workers int, stopCh <-chan struct{ … }
func (c *AvailableConditionController) runWorker() { … }
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 { … }
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{ … }