Method gather

internal/fluxshardoperator/controller.go:172–218

gather lists tenant HelmReleases and namespaces (metadata only) and groups them per tenant.

(ctx context.Context)

// gather lists tenant HelmReleases and namespaces (metadata only) and groups
// them per tenant.
func (r *PlacementReconciler) gather(ctx context.Context) (map[string]*tenantView, error) {
	hrs := HelmReleaseMetaList()
	if err := r.List(ctx, hrs, client.HasLabels{ShardKeyLabel}); err != nil {
		return nil, fmt.Errorf("listing HelmReleases: %w", err)
	}
	nss := NamespaceMetaList()
	if err := r.List(ctx, nss); err != nil {
		return nil, fmt.Errorf("listing namespaces: %w", err)
	}

	nsByName := make(map[string]*metav1.PartialObjectMetadata, len(nss.Items))
	for i := range nss.Items {
		nsByName[nss.Items[i].Name] = &nss.Items[i]
	}

	views := map[string]*tenantView{}
	for i := range hrs.Items {
		hr := &hrs.Items[i]
		tenantNS, ok := TenantNamespaceForHR(hr)
		if !ok {
			continue
		}
		v := views[tenantNS]
		if v == nil {
			v = &tenantView{info: TenantInfo{Namespace: tenantNS}}
			views[tenantNS] = v
		}
		v.hrs = append(v.hrs, hr)
		v.info.Weight++
	}

	for tenantNS, v := range views {
		if ns := nsByName[tenantNS]; ns != nil {
			v.nsExists = true
			v.info.Deleting = !ns.DeletionTimestamp.IsZero()
			v.nsLabel = ns.Labels[TenantShardLabel]
		}
		// The recorded assignment (namespace label) wins; HR labels are the
		// fallback source of truth when no assignment is recorded yet.
		if _, ok := ParseShardIndex(v.nsLabel); ok {
			v.info.Current = v.nsLabel
		} else {
			v.info.Current = majorityShard(v.hrs)
		}
	}
	return views, nil
}

// majorityShard returns the most common canonical shard value among the
// tenant's HelmRelease labels, tie-break lowest shard index. Legacy "tenants"