kubernetes/staging/src/k8s.io/kube-aggregator/pkg/apiserver/apiservice_controller.go

type APIHandlerManager …

type APIServiceRegistrationController …

var _ …

// NewAPIServiceRegistrationController returns a new APIServiceRegistrationController.
func NewAPIServiceRegistrationController(apiServiceInformer informers.APIServiceInformer, apiHandlerManager APIHandlerManager) *APIServiceRegistrationController { … }

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

// Run starts APIServiceRegistrationController which will process all registration requests until stopCh is closed.
func (c *APIServiceRegistrationController) Run(stopCh <-chan struct{ … }

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

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

func (c *APIServiceRegistrationController) enqueueInternal(obj *v1.APIService) { … }

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

func (c *APIServiceRegistrationController) updateAPIService(obj, _ interface{ … }

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

// Enqueue queues all apiservices to be rehandled.
// This method is used by the controller to notify when the proxy cert content changes.
func (c *APIServiceRegistrationController) Enqueue() { … }