code: func NewAggregationController(downloader *aggregator.Downloader, openAPIAggregationManager aggregator.SpecAggregator) *AggregationController {
  	c := &AggregationController{
  		openAPIAggregationManager: openAPIAggregationManager,
  		queue: workqueue.NewNamedRateLimitingQueue(
  			workqueue.NewItemExponentialFailureRateLimiter(successfulUpdateDelay, failedUpdateMaxExpDelay), "APIServiceOpenAPIAggregationControllerQueue1"),
  		downloader: downloader,
  	}
  
  	c.syncHandler = c.sync
  
  	// update each service at least once, also those which are not coming from APIServices, namely local services
  	for _, name := range openAPIAggregationManager.GetAPIServiceNames() {
  		c.queue.AddAfter(name, time.Second)
  	}
  
  	return c
  }
docs: // NewAggregationController creates new OpenAPI aggregation controller.