move store to static

cmd/cluster-agent/api/v2/series/job.go

@@ -62,7 +62,7 @@ func newJobQueue(ctx context.Context) *jobQueue {
 				Limiter: rate.NewLimiter(rate.Limit(payloadProcessQPS), payloadProcessRateBurst),
 			},
 		)),
-		store:     loadstore.NewEntityStore(ctx),
+		store:     loadstore.GetWorkloadMetricStore(ctx),
 		isStarted: false,
 	}
 	go q.start(ctx)
@@ -113,6 +113,9 @@ func (jq *jobQueue) reportTelemetry(ctx context.Context) {
 			case <-ctx.Done():
 				return
 			case <-infoTicker.C:
+				if jq.store == nil {
+					continue
+				}
 				info := jq.store.GetStoreInfo()
 				statsResults := info.StatsResults
 				for _, statsResult := range statsResults {

pkg/clusteragent/autoscaling/workload/loadstore/store.go

@@ -8,12 +8,27 @@
 package loadstore
 
 import (
+	"context"
 	"strings"
+	"sync"
 
 	"github.com/DataDog/agent-payload/v5/gogen"
 	"github.com/DataDog/datadog-agent/pkg/util/kubernetes"
 )
 
+var (
+	WorkloadMetricStore     Store
+	WorkloadMetricStoreOnce sync.Once
+)
+
+// GetWorkloadMetricStore returns the workload metric store, init once
+func GetWorkloadMetricStore(ctx context.Context) Store {
+	WorkloadMetricStoreOnce.Do(func() {
+		WorkloadMetricStore = NewEntityStore(ctx)
+	})
+	return WorkloadMetricStore
+}
+
 // StoreInfo represents the store information which aggregates the entities to lowest level, i.e., container level
 type StoreInfo struct {
 	currentTime  Timestamp