From 2cd44b263f5ec688124297f804bebcf7c743cf00 Mon Sep 17 00:00:00 2001 From: miampf Date: Thu, 8 Feb 2024 13:24:18 +0100 Subject: [PATCH] fixed issues from last rebase --- bootstrapper/cmd/bootstrapper/main.go | 11 +++++++---- bootstrapper/cmd/bootstrapper/run.go | 12 +++++------- hack/qemu-metadata-api/server/server.go | 1 - 3 files changed, 12 insertions(+), 12 deletions(-) diff --git a/bootstrapper/cmd/bootstrapper/main.go b/bootstrapper/cmd/bootstrapper/main.go index 94402e4b7f..30f6047242 100644 --- a/bootstrapper/cmd/bootstrapper/main.go +++ b/bootstrapper/cmd/bootstrapper/main.go @@ -110,11 +110,13 @@ func main() { case cloudprovider.Azure: metadata, err := azurecloud.New(ctx) if err != nil { - log.With(zap.Error(err)).Fatalf("Failed to create Azure metadata client") + log.With(slog.Any("error", err)).Error("Failed to create Azure metadata client") + os.Exit(1) } if err := metadata.PrepareControlPlaneNode(ctx, log); err != nil { - log.With(zap.Error(err)).Fatalf("Failed to prepare Azure control plane node") + log.With(slog.Any("error", err)).Error("Failed to prepare Azure control plane node") + os.Exit(1) } metadataAPI = metadata @@ -142,13 +144,14 @@ func main() { return tdx.Open() } default: - log.Fatalf("Unsupported attestation variant: %s", attestVariant) + log.Error(fmt.Sprintf("Unsupported attestation variant: %s", attestVariant)) } fs = afero.NewOsFs() case cloudprovider.OpenStack: metadata, err := openstackcloud.New(ctx) if err != nil { - log.With(zap.Error(err)).Fatalf("Failed to create OpenStack metadata client") + log.With(slog.Any("error", err)).Error("Failed to create OpenStack metadata client") + os.Exit(1); } clusterInitJoiner = kubernetes.New( "openstack", k8sapi.NewKubernetesUtil(), &k8sapi.KubdeadmConfiguration{}, kubectl.NewUninitialized(), diff --git a/bootstrapper/cmd/bootstrapper/run.go b/bootstrapper/cmd/bootstrapper/run.go index 22981eda65..733444beec 100644 --- a/bootstrapper/cmd/bootstrapper/run.go +++ b/bootstrapper/cmd/bootstrapper/run.go @@ -24,21 +24,19 @@ import ( "github.com/edgelesssys/constellation/v2/internal/constants" "github.com/edgelesssys/constellation/v2/internal/file" "github.com/edgelesssys/constellation/v2/internal/grpc/dialer" - "github.com/edgelesssys/constellation/v2/internal/logger" - "go.uber.org/zap" ) func run(issuer atls.Issuer, openDevice vtpm.TPMOpenFunc, fileHandler file.Handler, kube clusterInitJoiner, metadata metadataAPI, - bindIP, bindPort string, log *logger.Logger, + bindIP, bindPort string, log *slog.Logger, ) { - log.With(zap.String("version", constants.BinaryVersion().String())).Infof("Starting bootstrapper") + log.With(slog.String("version", constants.BinaryVersion().String())).Info("Starting bootstrapper") uuid, err := getDiskUUID() if err != nil { - log.With(zap.Error(err)).Errorf("Failed to get disk UUID") + log.With(slog.Any("error", err)).Error("Failed to get disk UUID") } else { - log.Infof("Disk UUID: %s", uuid) + log.Info(fmt.Sprintf("Disk UUID: %s", uuid)) } nodeBootstrapped, err := initialize.IsNodeBootstrapped(openDevice) @@ -76,7 +74,7 @@ func run(issuer atls.Issuer, openDevice vtpm.TPMOpenFunc, fileHandler file.Handl os.Exit(1) } - log.Infof("bootstrapper done") + log.Info("bootstrapper done") } func getDiskUUID() (string, error) { diff --git a/hack/qemu-metadata-api/server/server.go b/hack/qemu-metadata-api/server/server.go index aa4e71e7c6..4f0cad9e97 100644 --- a/hack/qemu-metadata-api/server/server.go +++ b/hack/qemu-metadata-api/server/server.go @@ -9,7 +9,6 @@ package server import ( "encoding/json" "fmt" - "io" "log/slog" "net" "net/http"