Collects ClusterId for Telemetry Object Collector

internal/mode/static/telemetry/collector.go

@@ -14,6 +14,9 @@ import (
 	"github.com/nginxinc/nginx-gateway-fabric/internal/mode/static/state/graph"
 )
 
+// kubeSystem indicates the name of kube-system namespace
+const kubeSystem = "kube-system"
+
 //go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 . GraphGetter
 
 // GraphGetter gets the latest Graph.
@@ -49,6 +52,7 @@ type ProjectMetadata struct {
 // Note: this type might change once https://github.com/nginxinc/nginx-gateway-fabric/issues/1318 is implemented.
 type Data struct {
 	ProjectMetadata   ProjectMetadata
+	ClusterID         string
 	NodeCount         int
 	NGFResourceCounts NGFResourceCounts
 	NGFReplicaCount   int
@@ -99,6 +103,11 @@ func (c DataCollectorImpl) Collect(ctx context.Context) (Data, error) {
 		return Data{}, fmt.Errorf("failed to collect NGF replica count: %w", err)
 	}
 
+	var clusterID string
+	if clusterID, err = collectClusterID(ctx, c.cfg.K8sClientReader); err != nil {
+		return Data{}, fmt.Errorf("failed to collect clusterID: %w", err)
+	}
+
 	data := Data{
 		NodeCount:         nodeCount,
 		NGFResourceCounts: graphResourceCount,
@@ -107,6 +116,7 @@ func (c DataCollectorImpl) Collect(ctx context.Context) (Data, error) {
 			Version: c.cfg.Version,
 		},
 		NGFReplicaCount: ngfReplicaCount,
+		ClusterID:       clusterID,
 	}
 
 	return data, nil
@@ -193,3 +203,15 @@ func collectNGFReplicaCount(ctx context.Context, k8sClient client.Reader, podNSN
 
 	return int(*replicaSet.Spec.Replicas), nil
 }
+
+func collectClusterID(ctx context.Context, k8sClient client.Reader) (string, error) {
+	key := types.NamespacedName{
+		Name: kubeSystem,
+	}
+	var kubeNamespace v1.Namespace
+	err := k8sClient.Get(ctx, key, &kubeNamespace)
+	if err != nil {
+		return "", fmt.Errorf("failed to get namespace :%w", err)
+	}
+	return string(kubeNamespace.GetUID()), nil
+}