Method StartHealthCheck

pkg/api/cluster_client.go:207–220

StartHealthCheck begins periodic health checking of the active node. If the active node becomes unreachable, it automatically triggers failover. The health check pings the /api2/json/version endpoint which is lightweight.

()

// If the active node becomes unreachable, it automatically triggers failover.
// The health check pings the /api2/json/version endpoint which is lightweight.
func (cc *ClusterClient) StartHealthCheck() {
	cc.mu.Lock()
	defer cc.mu.Unlock()

	// Stop any existing health check
	cc.stopHealthCheckLocked()

	cc.healthStop = make(chan struct{})
	cc.healthTicker = time.NewTicker(cc.healthInterval)

	go cc.healthCheckLoop()

	cc.logger.Info("[CLUSTER] Health check started (interval: %s)", cc.healthInterval)
}

// StopHealthCheck stops the periodic health checking.
func (cc *ClusterClient) StopHealthCheck() {