Skip to content

Commit d5d4d7c

Browse files
committed
Address PR feedback
1 parent a9378a8 commit d5d4d7c

File tree

5 files changed

+30
-50
lines changed

5 files changed

+30
-50
lines changed

build/Dockerfile

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,8 @@ COPY go.mod go.sum /go/src/github.com/nginxinc/nginx-gateway-kubernetes
99
RUN go mod download
1010

1111
COPY cmd /go/src/github.com/nginxinc/nginx-gateway-kubernetes/cmd
12+
COPY internal /go/src/github.com/nginxinc/nginx-gateway-kubernetes/internal
13+
COPY pkg /go/src/github.com/nginxinc/nginx-gateway-kubernetes/pkg
1214
RUN CGO_ENABLED=0 GOOS=linux go build -trimpath -a -ldflags "-s -w -X main.version=${VERSION} -X main.commit=${GIT_COMMIT} -X main.date=${DATE}" -o gateway .
1315

1416
FROM scratch as common

cmd/gateway/main.go

Lines changed: 21 additions & 43 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,16 @@
11
package main
22

33
import (
4-
"context"
54
"flag"
65
"fmt"
76
"os"
8-
"os/signal"
9-
"syscall"
107

118
"github.com/nginxinc/nginx-gateway-kubernetes/internal/implementation"
12-
"github.com/nginxinc/nginx-gateway-kubernetes/internal/sdk"
13-
"go.uber.org/zap"
9+
"github.com/nginxinc/nginx-gateway-kubernetes/pkg/sdk"
1410
"k8s.io/client-go/rest"
15-
"sigs.k8s.io/controller-runtime/pkg/log"
16-
rzap "sigs.k8s.io/controller-runtime/pkg/log/zap"
11+
"sigs.k8s.io/controller-runtime/pkg/log/zap"
1712
"sigs.k8s.io/controller-runtime/pkg/manager"
13+
"sigs.k8s.io/controller-runtime/pkg/manager/signals"
1814
"sigs.k8s.io/gateway-api/apis/v1alpha2"
1915
)
2016

@@ -36,62 +32,44 @@ func main() {
3632
os.Exit(1)
3733
}
3834

39-
logger, err := zap.NewProduction()
40-
if err != nil {
41-
fmt.Fprintf(os.Stderr, "Failed to initialize logging: %v\n", err)
42-
os.Exit(1)
43-
}
44-
sugar := logger.Sugar()
35+
logger := zap.New()
4536

46-
sugar.Infow("Starting NGINX Gateway",
37+
logger.Info("Starting NGINX Gateway",
4738
"version", version,
4839
"commit", commit,
4940
"date", date)
5041

5142
config, err := rest.InClusterConfig()
5243
if err != nil {
53-
sugar.Fatalw("Failed to create InClusterConfig",
54-
"error", err)
44+
logger.Error(err, "Failed to create InClusterConfig")
45+
os.Exit(1)
5546
}
5647

57-
log.SetLogger(rzap.New())
58-
59-
mgr, err := manager.New(config, manager.Options{})
48+
mgr, err := manager.New(config, manager.Options{
49+
Logger: logger,
50+
})
6051
if err != nil {
61-
sugar.Fatalw("Failed to create Manager",
62-
"error", err)
52+
logger.Error(err, "Failed to create Manager")
53+
os.Exit(1)
6354
}
6455

6556
err = v1alpha2.AddToScheme(mgr.GetScheme())
6657
if err != nil {
67-
if err != nil {
68-
sugar.Fatalw("Failed to add Gateway API scheme",
69-
"error", err)
70-
}
58+
logger.Error(err, "Failed to add Gateway API scheme")
59+
os.Exit(1)
7160
}
7261

73-
err = sdk.RegisterGatewayClassController(mgr, implementation.NewGatewayClassImplementation(sugar))
62+
err = sdk.RegisterGatewayClassController(mgr, implementation.NewGatewayClassImplementation(logger))
7463
if err != nil {
75-
sugar.Fatalw("Failed to register GatewayClassController",
76-
"error", err)
64+
logger.Error(err, "Failed to register GatewayClassController")
65+
os.Exit(1)
7766
}
7867

79-
sugar.Infow("Starting manager")
80-
81-
ctx, cancel := context.WithCancel(context.Background())
82-
signalChan := make(chan os.Signal, 1)
83-
signal.Notify(signalChan, os.Interrupt, syscall.SIGTERM)
84-
go func() {
85-
sugar.Infow("Terminating because of the signal",
86-
"signal", <-signalChan)
68+
logger.Info("Starting manager")
8769

88-
cancel()
89-
os.Exit(0)
90-
}()
91-
92-
err = mgr.Start(ctx)
70+
err = mgr.Start(signals.SetupSignalHandler())
9371
if err != nil {
94-
sugar.Fatalw("Failed to start Manager",
95-
"error", err)
72+
logger.Error(err, "Failed to start Manager")
73+
os.Exit(1)
9674
}
9775
}
Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1,31 +1,31 @@
11
package implementation
22

33
import (
4-
"github.com/nginxinc/nginx-gateway-kubernetes/internal/sdk"
5-
"go.uber.org/zap"
4+
"github.com/go-logr/logr"
5+
"github.com/nginxinc/nginx-gateway-kubernetes/pkg/sdk"
66
"sigs.k8s.io/gateway-api/apis/v1alpha2"
77
)
88

99
type gatewayClassImplementation struct {
10-
logger *zap.SugaredLogger
10+
logger logr.Logger
1111
}
1212

13-
func NewGatewayClassImplementation(logger *zap.SugaredLogger) sdk.GatewayClassImpl {
13+
func NewGatewayClassImplementation(logger logr.Logger) sdk.GatewayClassImpl {
1414
return &gatewayClassImplementation{logger: logger}
1515
}
1616

1717
func (impl *gatewayClassImplementation) Upsert(gc *v1alpha2.GatewayClass) {
1818
if gc.Spec.ControllerName != "k8s-gateway.nginx.org/gateway" {
19-
impl.logger.Errorw("Wrong ControllerName in the GatewayClass resource",
19+
impl.logger.Info("Wrong ControllerName in the GatewayClass resource",
2020
"expected", "k8s-gateway.nginx.org/gateway",
2121
"got", "gc.Spec.ControllerName")
2222
return
2323
}
2424

25-
impl.logger.Infow("Processing GatewayClass resource",
25+
impl.logger.Info("Processing GatewayClass resource",
2626
"name", gc.Name)
2727
}
2828
func (impl *gatewayClassImplementation) Remove(key string) {
29-
impl.logger.Errorw("GatewayClass resource was removed",
29+
impl.logger.Info("GatewayClass resource was removed",
3030
"name", key)
3131
}
File renamed without changes.
File renamed without changes.

0 commit comments

Comments
 (0)