From 9b92890656216c9fde6941f163b96d633550eca6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=EA=B9=80=EB=8B=A4=EA=B2=BD=28Da=20Gyeong=20Kim=29?= <65109465+S0okJu@users.noreply.github.com> Date: Mon, 4 Aug 2025 17:32:36 +0900 Subject: [PATCH] Revert "Feat: Remove promethues custom matrix logic" --- cmd/main.go | 15 +++++++++++++++ internal/controller/v2/custom_metrics.go | 21 +++++++++++++++++++++ 2 files changed, 36 insertions(+) create mode 100644 internal/controller/v2/custom_metrics.go diff --git a/cmd/main.go b/cmd/main.go index 06e241c..861b902 100644 --- a/cmd/main.go +++ b/cmd/main.go @@ -152,9 +152,24 @@ func main() { os.Exit(1) } + // Kafka + // kafkaBrokers := strings.Split(os.Getenv("KAFKA_BROKERS"), ",") + // if len(kafkaBrokers) == 0 { + // kafkaBrokers = []string{"localhost:9093"} // 9093 포트 사용 + // } + + // kafkaProducer, err := kafka.NewKafkaProducer(kafkaBrokers) + // if err != nil { + // setupLog.Error(err, "unable to create kafka producer") + // os.Exit(1) + // } + + // defer kafkaProducer.Close() + if err = (&controller.ChallengeReconciler{ Client: mgr.GetClient(), Scheme: mgr.GetScheme(), + // KafkaClient: kafkaProducer, }).SetupWithManager(mgr); err != nil { setupLog.Error(err, "unable to create controller", "controller", "Challenge") os.Exit(1) diff --git a/internal/controller/v2/custom_metrics.go b/internal/controller/v2/custom_metrics.go new file mode 100644 index 0000000..060d881 --- /dev/null +++ b/internal/controller/v2/custom_metrics.go @@ -0,0 +1,21 @@ +package controller + +import ( + "github.com/prometheus/client_golang/prometheus" + "sigs.k8s.io/controller-runtime/pkg/metrics" +) + +var ( + crStatusMetric = prometheus.NewGaugeVec( + prometheus.GaugeOpts{ + Name: "challenge_resource_status", + Help: "Tracks the status of the custom resource", + }, + []string{"challeng_id", "challenge_name", "username", "namespace"}, + ) +) + +func init() { + metrics.Registry.MustRegister(crStatusMetric) + +}