in controllers/periodic_healthcheck.go [37:51]
func (r *EtcdadmClusterReconciler) startHealthCheckLoop(ctx context.Context, done <-chan struct{}) {
r.Log.Info("Starting periodic healthcheck loop")
etcdadmClusterMapper := make(map[types.UID]etcdadmClusterMemberHealthConfig)
ticker := time.NewTicker(r.HealthCheckInterval)
defer ticker.Stop()
for {
select {
case <-done:
return
case <-ticker.C:
r.startHealthCheck(ctx, etcdadmClusterMapper)
}
}
}