Method GetGroupClusterResources

pkg/api/grouped-cluster.go:274–319

GetGroupClusterResources retrieves cluster resources from all profiles in the group. This provides a unified view of all resources across all connected profiles. fresh flag bypasses caches when true.

(ctx context.Context, fresh bool)

// This provides a unified view of all resources across all connected profiles.
// fresh flag bypasses caches when true.
func (m *GroupClientManager) GetGroupClusterResources(ctx context.Context, fresh bool) ([]*Node, []*VM, error) {
	// Use goroutines to fetch nodes and VMs concurrently for better performance
	type result struct {
		nodes []*Node
		vms   []*VM
		err   error
	}

	nodesChan := make(chan result, 1)
	vmsChan := make(chan result, 1)

	// Fetch nodes
	go func() {
		if fresh {
			// Selectively invalidate cluster-level cache keys per profile
			// instead of wiping the entire cache (preserves node disks, updates, etc.)
			for _, pc := range m.GetConnectedClients() {
				if pc.Client != nil {
					pc.Client.ClearClusterCache()
				}
			}
		}
		nodes, err := m.GetGroupNodes(ctx)
		nodesChan <- result{nodes: nodes, err: err}
	}()

	// Fetch VMs
	go func() {
		vms, err := m.GetGroupVMs(ctx)
		vmsChan <- result{vms: vms, err: err}
	}()

	// Wait for both operations to complete
	nodesResult := <-nodesChan
	vmsResult := <-vmsChan

	if nodesResult.err != nil {
		return nil, nil, fmt.Errorf("failed to get group nodes: %w", nodesResult.err)
	}

	if vmsResult.err != nil {
		return nil, nil, fmt.Errorf("failed to get group VMs: %w", vmsResult.err)
	}

	return nodesResult.nodes, vmsResult.vms, nil
}

// GetNodeFromGroup retrieves a specific node from a specific profile.
// This is useful when you need to perform operations on a node and need to ensure