Skip to content

Commit

Permalink
add(config): loglevel
Browse files Browse the repository at this point in the history
  • Loading branch information
ybelMekk committed Aug 22, 2023
1 parent 1335937 commit 3f54d24
Show file tree
Hide file tree
Showing 2 changed files with 16 additions and 9 deletions.
23 changes: 14 additions & 9 deletions cmd/jwker/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,6 +2,7 @@ package main

import (
"os"
"strings"
"time"

"github.com/go-logr/zapr"
Expand Down Expand Up @@ -50,21 +51,21 @@ func init() {
}

func main() {
zapLogger, err := setupZapLogger()
cfg, err := config.New()
if err != nil {
log.Fatalf("unable to set up logger: %+v", err)
setupLog.Error(err, "initializing config")
os.Exit(1)
}

ctrl.SetLogger(zapr.NewLogger(zapLogger))
setupLog.Info("starting jwker")

cfg, err := config.New()
zapLogger, err := setupZapLogger(cfg.LogLevel)
if err != nil {
setupLog.Error(err, "initializing config")
log.Fatalf("unable to set up logger: %+v", err)
os.Exit(1)
}

ctrl.SetLogger(zapr.NewLogger(zapLogger))
setupLog.Info("starting jwker")

mgr, err := ctrl.NewManager(ctrl.GetConfigOrDie(), ctrl.Options{
Scheme: scheme,
MetricsBindAddress: cfg.MetricsAddr,
Expand Down Expand Up @@ -99,9 +100,13 @@ func main() {
}
}

func setupZapLogger() (*zap.Logger, error) {
func setupZapLogger(logLevel string) (*zap.Logger, error) {
loggerConfig := zap.NewProductionConfig()
loggerConfig.Level = zap.NewAtomicLevelAt(zap.DebugLevel)
level, err := zap.ParseAtomicLevel(strings.ToLower(logLevel))
if err != nil {
return nil, err
}
loggerConfig.Level = level
loggerConfig.EncoderConfig.TimeKey = "timestamp"
loggerConfig.EncoderConfig.EncodeTime = zapcore.RFC3339NanoTimeEncoder
return loggerConfig.Build()
Expand Down
2 changes: 2 additions & 0 deletions pkg/config/config.go
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,7 @@ import (
type Config struct {
AuthProvider AuthProvider
ClusterName string
LogLevel string
MetricsAddr string
Tokendings Tokendings
}
Expand Down Expand Up @@ -45,6 +46,7 @@ func New() (*Config, error) {
flag.StringVar(&cfg.MetricsAddr, "metrics-addr", ":8181", "The address the metric endpoint binds to.")
flag.StringVar(&cfg.Tokendings.BaseURL, "tokendings-base-url", os.Getenv("TOKENDINGS_URL"), "Base URL to Tokendings.")
flag.StringVar(&cfg.Tokendings.ClientID, "tokendings-client-id", os.Getenv("TOKENDINGS_CLIENT_ID"), "Client ID of Tokendings at Auth Provider")
flag.StringVar(&cfg.LogLevel, "log-level", "info", "Log level for jwker")
flag.Parse()

j, err := jwkutils.ParseJWK([]byte(clientJwkJson))
Expand Down

0 comments on commit 3f54d24

Please sign in to comment.