From 4d6326b8be9bef9d730ea010ae933d43e43ad9a1 Mon Sep 17 00:00:00 2001 From: Jan Eitzinger Date: Mon, 12 Jan 2026 08:55:31 +0100 Subject: [PATCH] Remove metricsync --- internal/metricsync/metricdata.go | 60 ------------------------------- 1 file changed, 60 deletions(-) delete mode 100644 internal/metricsync/metricdata.go diff --git a/internal/metricsync/metricdata.go b/internal/metricsync/metricdata.go deleted file mode 100644 index 772f16da..00000000 --- a/internal/metricsync/metricdata.go +++ /dev/null @@ -1,60 +0,0 @@ -// Copyright (C) NHR@FAU, University Erlangen-Nuremberg. -// All rights reserved. This file is part of cc-backend. -// Use of this source code is governed by a MIT-style -// license that can be found in the LICENSE file. - -package metricsync - -import ( - "context" - "encoding/json" - "fmt" - "time" - - "github.com/ClusterCockpit/cc-backend/internal/config" - cclog "github.com/ClusterCockpit/cc-lib/v2/ccLogger" - "github.com/ClusterCockpit/cc-lib/v2/schema" -) - -type MetricDataSource interface { - // Initialize this MetricDataRepository. One instance of - // this interface will only ever be responsible for one cluster. - Init(rawConfig json.RawMessage) error - - // Return a map of hosts to a map of metrics at the requested scopes (currently only node) for that node. - Pull(cluster string, metrics, nodes []string, scopes []schema.MetricScope, from, to time.Time, ctx context.Context) (map[string]map[string][]*schema.JobMetric, error) -} - -var metricDataSourceRepos map[string]MetricDataSource = map[string]MetricDataSource{} - -func Init() error { - for _, cluster := range config.Clusters { - if cluster.MetricDataRepository != nil { - var kind struct { - Kind string `json:"kind"` - } - if err := json.Unmarshal(cluster.MetricDataRepository, &kind); err != nil { - cclog.Warn("Error while unmarshaling raw json MetricDataRepository") - return err - } - - var mdr MetricDataSource - switch kind.Kind { - case "cc-metric-store": - case "prometheus": - // mdr = &PrometheusDataRepository{} - case "test": - // mdr = &TestMetricDataRepository{} - default: - return fmt.Errorf("METRICDATA/METRICDATA > Unknown MetricDataRepository %v for cluster %v", kind.Kind, cluster.Name) - } - - if err := mdr.Init(cluster.MetricDataRepository); err != nil { - cclog.Errorf("Error initializing MetricDataRepository %v for cluster %v", kind.Kind, cluster.Name) - return err - } - metricDataSourceRepos[cluster.Name] = mdr - } - } - return nil -}