Method performHealthCheck

pkg/api/cluster_client.go:263–296

performHealthCheck pings the active node and triggers failover if unreachable.

()

// performHealthCheck pings the active node and triggers failover if unreachable.
func (cc *ClusterClient) performHealthCheck() {
	cc.mu.RLock()
	client := cc.activeClient
	profile := cc.activeProfile
	cc.mu.RUnlock()

	if client == nil {
		return
	}

	// Use a short timeout for health checks
	ctx, cancel := context.WithTimeout(context.Background(), DefaultHealthCheckTimeout)
	defer cancel()

	// Ping the version endpoint — lightweight, no auth issues
	var result map[string]interface{}
	err := client.httpClient.GetWithRetry(ctx, healthCheckPath, &result, 1)
	if err != nil {
		cc.logger.Error("[CLUSTER] Health check failed for %s: %v", profile, err)
		cc.logger.Info("[CLUSTER] Triggering automatic failover")

		// Trigger failover
		cc.mu.Lock()
		failoverErr := cc.failoverLocked(ctx)
		cc.mu.Unlock()

		if failoverErr != nil {
			cc.logger.Error("[CLUSTER] Automatic failover failed: %v", failoverErr)
		}
		return
	}

	cc.logger.Debug("[CLUSTER] Health check OK for %s", profile)
}

// Close stops health checks and cleans up resources.
func (cc *ClusterClient) Close() {