prow/statusreconciler/controller.go
func (c *Controller) Run(stop <-chan os.Signal, changes <-chan config.Delta) {
	for {
		select {
		case change := <-changes:
			start := time.Now()
			if err := c.reconcile(change); err != nil {
				logrus.WithError(err).Error("Error reconciling statuses.")
			}
			logrus.WithField("duration", fmt.Sprintf("%v", time.Since(start))).Info("Statuses reconciled")
		case <-stop:
			logrus.Info("status-reconciler is shutting down...")
			return
		}
	}
}
func (c *Controller) Run(stop <-chan os.Signal, changes <-chan config.Delta) {
	for {
		select {
		case change := <-changes:
			start := time.Now()
			if err := c.reconcile(change); err != nil {
				logrus.WithError(err).Error("Error reconciling statuses.")
			}
			logrus.WithField("duration", fmt.Sprintf("%v", time.Since(start))).Info("Statuses reconciled")
		case <-stop:
			logrus.Info("status-reconciler is shutting down...")
			return
		}
	}
}
func ( c * Controller ) Run ( stop <- chan os . Signal , changes <- chan config . Delta ) { for { select { case change := <- changes : start := time . Now ( ) if err := c . reconcile ( change ) ; err != nil { logrus . WithError ( err ) . Error ( " " ) } logrus . WithField ( " " , fmt . Sprintf ( " " , time . Since ( start ) ) ) . Info ( " " ) case <- stop : logrus . Info ( " " ) return } } }
// Run monitors the incoming configuration changes to determine when statuses need to be
// reconciled on PRs in flight when blocking presubmits change
Run monitors the incoming configuration changes to determine when statuses need to be reconciled on PRs in flight when blocking presubmits change