in pkg/controllers/cloudmap_controller.go [37:52]
func (r *CloudMapReconciler) Start(ctx context.Context) error {
ticker := time.NewTicker(syncPeriod)
defer ticker.Stop()
for {
if err := r.Reconcile(ctx); err != nil {
// just log the error and continue running
r.Log.Error(err, "Cloud Map reconciliation error")
}
select {
case <-ticker.C:
case <-ctx.Done():
r.Log.Info("terminating CloudMapReconciler")
return nil
}
}
}