Adding get cluster id call and bumping go version on dockerfile (#208)

build/kafka-watcher.Dockerfile

@@ -1,4 +1,4 @@
-FROM --platform=$BUILDPLATFORM golang:1.21-alpine as buildenv
+FROM --platform=$BUILDPLATFORM golang:1.22.1-alpine as buildenv
 RUN apk add --no-cache ca-certificates git protoc
 RUN apk add build-base libpcap-dev
 WORKDIR /src

build/mapper.Dockerfile

@@ -1,4 +1,4 @@
-FROM --platform=$BUILDPLATFORM golang:1.21-alpine as buildenv
+FROM --platform=$BUILDPLATFORM golang:1.22.1-alpine as buildenv
 RUN apk add --no-cache ca-certificates git protoc
 RUN apk add build-base libpcap-dev
 WORKDIR /src

build/sniffer.Dockerfile

@@ -1,4 +1,4 @@
-FROM --platform=linux/amd64 golang:1.21-alpine as buildenv
+FROM --platform=linux/amd64 golang:1.22.1-alpine as buildenv
 RUN apk add --no-cache ca-certificates git protoc
 RUN apk add build-base libpcap-dev
 WORKDIR /src
@@ -14,7 +14,7 @@ RUN go test ./sniffer/... && echo dep > /dep
 
 # We start from the base image again, only this time it's using the target arch instead of always amd64. This is done to make the build faster.
 # Unlike the mapper, it can't be amd64 throughout and use Go's cross-compilation, since the sniffer depends on libpcap (C library).
-FROM golang:1.21-alpine as builder
+FROM golang:1.22.1-alpine as builder
 COPY --from=test /dep /dep
 RUN apk add --no-cache ca-certificates git protoc
 RUN apk add build-base libpcap-dev

src/mapper/cmd/main.go

@@ -4,9 +4,9 @@ import (
 	"context"
 	"fmt"
 	"github.com/bombsimon/logrusr/v3"
-	"github.com/google/uuid"
 	"github.com/labstack/echo-contrib/echoprometheus"
 	mutatingwebhookconfiguration "github.com/otterize/intents-operator/src/operator/controllers/mutating_webhook_controller"
+	"github.com/otterize/intents-operator/src/shared/clusterutils"
 	"github.com/otterize/intents-operator/src/shared/errors"
 	"github.com/otterize/intents-operator/src/shared/filters"
 	"github.com/otterize/intents-operator/src/shared/telemetries/componentinfo"
@@ -21,11 +21,8 @@ import (
 	"github.com/otterize/network-mapper/src/mapper/pkg/pod_webhook"
 	"github.com/otterize/network-mapper/src/shared/echologrus"
 	"golang.org/x/sync/errgroup"
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/runtime"
-	"k8s.io/apimachinery/pkg/runtime/schema"
 	utilruntime "k8s.io/apimachinery/pkg/util/runtime"
-	"k8s.io/client-go/metadata"
 	"net/http"
 	"os"
 	"sigs.k8s.io/controller-runtime/pkg/metrics/server"
@@ -56,7 +53,6 @@ import (
 	ctrl "sigs.k8s.io/controller-runtime"
 	clientconfig "sigs.k8s.io/controller-runtime/pkg/client/config"
 	"sigs.k8s.io/controller-runtime/pkg/manager"
-	"sigs.k8s.io/controller-runtime/pkg/manager/signals"
 )
 
 var (
@@ -108,8 +104,9 @@ func main() {
 	if err != nil {
 		logrus.Panicf("unable to set up overall controller manager: %s", err)
 	}
+	signalHandlerCtx := ctrl.SetupSignalHandler()
 
-	errgrp, errGroupCtx := errgroup.WithContext(signals.SetupSignalHandler())
+	errgrp, errGroupCtx := errgroup.WithContext(signalHandlerCtx)
 
 	dnsCache := dnscache.NewDNSCache()
 	dnsPublisher, dnsPublisherEnabled, err := dnsintentspublisher.InitWithManager(errGroupCtx, mgr, dnsCache)
@@ -139,23 +136,12 @@ func main() {
 		return nil
 	})
 
-	metadataClient, err := metadata.NewForConfig(clientconfig.GetConfigOrDie())
+	clusterUID, err := clusterutils.GetOrCreateClusterUID(signalHandlerCtx)
 	if err != nil {
-		logrus.WithError(err).Panic("unable to create metadata client")
+		logrus.WithError(err).Panic("Failed fetching cluster UID")
 	}
-	mapping, err := mgr.GetRESTMapper().RESTMapping(schema.GroupKind{Group: "", Kind: "Namespace"}, "v1")
-	if err != nil {
-		logrus.WithError(err).Panic("unable to create Kubernetes API REST mapping")
-	}
-	kubeSystemUID := ""
-	kubeSystemNs, err := metadataClient.Resource(mapping.Resource).Get(context.Background(), "kube-system", metav1.GetOptions{})
-	if err != nil || kubeSystemNs == nil {
-		logrus.Warningf("failed getting kubesystem UID: %s", err)
-		kubeSystemUID = fmt.Sprintf("rand-%s", uuid.New().String())
-	} else {
-		kubeSystemUID = string(kubeSystemNs.UID)
-	}
-	componentinfo.SetGlobalContextId(telemetrysender.Anonymize(kubeSystemUID))
+
+	componentinfo.SetGlobalContextId(telemetrysender.Anonymize(clusterUID))
 
 	// start API server
 	mapperServer.GET("/healthz", func(c echo.Context) error {