kubernetes/staging/src/k8s.io/kube-aggregator/pkg/controllers/openapi/controller.go

const successfulUpdateDelay …

const successfulUpdateDelayLocal …

const failedUpdateMaxExpDelay …

type syncAction …

const syncRequeue …

const syncRequeueRateLimited …

const syncNothing …

type AggregationController …

// NewAggregationController creates new OpenAPI aggregation controller.
func NewAggregationController(downloader *aggregator.Downloader, openAPIAggregationManager aggregator.SpecAggregator) *AggregationController { … }

// Run starts OpenAPI AggregationController
func (c *AggregationController) Run(stopCh <-chan struct{ … }

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

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

func (c *AggregationController) sync(key string) (syncAction, error) { … }

// AddAPIService adds a new API Service to OpenAPI Aggregation.
func (c *AggregationController) AddAPIService(handler http.Handler, apiService *v1.APIService) { … }

// UpdateAPIService updates API Service's info and handler.
func (c *AggregationController) UpdateAPIService(handler http.Handler, apiService *v1.APIService) { … }

// RemoveAPIService removes API Service from OpenAPI Aggregation Controller.
func (c *AggregationController) RemoveAPIService(apiServiceName string) { … }