Method CountActiveReplicas

backend/enterprise/license.go:485–505

CountActiveReplicas returns the count of active replicas. A replica is considered active if it has sent a heartbeat within the last 30 seconds. Returns at least 1 (the current replica is always counted).

(ctx context.Context)

// A replica is considered active if it has sent a heartbeat within the last 30 seconds.
// Returns at least 1 (the current replica is always counted).
func (s *LicenseService) CountActiveReplicas(ctx context.Context) int {
	if state := s.replicaCache.Load(); state != nil && time.Since(state.loadedAt) < replicaActiveWindow {
		return state.replicaCount
	}

	count, err := s.store.CountActiveReplicas(ctx, replicaActiveWindow)
	if err != nil {
		slog.Warn("failed to count active replicas", log.BBError(err))
		return 1
	}

	if count < 1 {
		count = 1
	}
	s.replicaCache.Store(&replicaCacheState{
		replicaCount: count,
		loadedAt:     time.Now(),
	})

	return count
}

// CheckReplicaLimit checks if the current replica count exceeds the allowed limit.
// Returns error if HA is not allowed and there are multiple active replicas.