Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions cmd/activator/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -127,11 +127,11 @@ func main() {
flag.Parse()
cm, err := configmap.Load("/etc/config-logging")
if err != nil {
log.Fatalf("Error loading logging configuration: %v", err)
log.Fatal("Error loading logging configuration:", err)
}
logConfig, err := logging.NewConfigFromMap(cm)
if err != nil {
log.Fatalf("Error parsing logging configuration: %v", err)
log.Fatal("Error parsing logging configuration:", err)
}
createdLogger, atomicLevel := logging.NewLoggerFromConfig(logConfig, component)
logger := createdLogger.With(zap.String(logkey.ControllerType, "activator"))
Expand Down Expand Up @@ -189,7 +189,7 @@ func main() {
endpointInformer.Informer(),
serviceInformer.Informer(),
sksInformer.Informer()); err != nil {
logger.Fatalf("Failed to start informers: %v", err)
logger.Fatalw("Failed to start informers", err)
}

params := queue.BreakerParams{QueueDepth: breakerQueueDepth, MaxConcurrency: breakerMaxConcurrency, InitialCapacity: 0}
Expand Down
6 changes: 3 additions & 3 deletions cmd/autoscaler/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -123,7 +123,7 @@ func main() {
serviceInformer.Informer(),
sksInformer.Informer(),
); err != nil {
logger.Fatalf("Failed to start informers: %v", err)
logger.Fatalw("Failed to start informers", err)
}

go controller.StartAll(stopCh, controllers...)
Expand Down Expand Up @@ -162,11 +162,11 @@ func main() {
func setupLogger() (*zap.SugaredLogger, zap.AtomicLevel) {
loggingConfigMap, err := configmap.Load("/etc/config-logging")
if err != nil {
log.Fatalf("Error loading logging configuration: %v", err)
log.Fatal("Error loading logging configuration:", err)
}
loggingConfig, err := logging.NewConfigFromMap(loggingConfigMap)
if err != nil {
log.Fatalf("Error parsing logging configuration: %v", err)
log.Fatal("Error parsing logging configuration:", err)
}
return logging.NewLoggerFromConfig(loggingConfig, component)
}
Expand Down
6 changes: 3 additions & 3 deletions cmd/controller/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -60,11 +60,11 @@ func main() {
// Set up our logger.
loggingConfigMap, err := configmap.Load("/etc/config-logging")
if err != nil {
log.Fatalf("Error loading logging configuration: %v", err)
log.Fatal("Error loading logging configuration:", err)
}
loggingConfig, err := logging.NewConfigFromMap(loggingConfigMap)
if err != nil {
log.Fatalf("Error parsing logging configuration: %v", err)
log.Fatal("Error parsing logging configuration:", err)
}
logger, atomicLevel := logging.NewLoggerFromConfig(loggingConfig, component)
defer flush(logger)
Expand Down Expand Up @@ -176,7 +176,7 @@ func main() {
serviceInformer.Informer(),
sksInformer.Informer(),
); err != nil {
logger.Fatalf("Failed to start informers: %v", err)
logger.Fatalw("Failed to start informers", err)
}

// Start all of the controllers.
Expand Down
4 changes: 2 additions & 2 deletions cmd/networking/istio/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -50,11 +50,11 @@ func main() {
// Set up our logger.
loggingConfigMap, err := configmap.Load("/etc/config-logging")
if err != nil {
log.Fatalf("Error loading logging configuration: %v", err)
log.Fatal("Error loading logging configuration:", err)
}
loggingConfig, err := logging.NewConfigFromMap(loggingConfigMap)
if err != nil {
log.Fatalf("Error parsing logging configuration: %v", err)
log.Fatal("Error parsing logging configuration:", err)
}
logger, atomicLevel := logging.NewLoggerFromConfig(loggingConfig, component)
defer logger.Sync()
Expand Down
2 changes: 1 addition & 1 deletion cmd/queue/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -305,7 +305,7 @@ func main() {
// Calling server.Shutdown() allows pending requests to
// complete, while no new work is accepted.
if err := server.Shutdown(context.Background()); err != nil {
logger.Errorf("Failed to shutdown proxy server", zap.Error(err))
logger.Errorw("Failed to shutdown proxy server", zap.Error(err))
}
})

Expand Down
6 changes: 3 additions & 3 deletions cmd/webhook/main.go
Original file line number Diff line number Diff line change
Expand Up @@ -53,11 +53,11 @@ func main() {
flag.Parse()
cm, err := configmap.Load("/etc/config-logging")
if err != nil {
log.Fatalf("Error loading logging configuration: %v", err)
log.Fatal("Error loading logging configuration:", err)
}
config, err := logging.NewConfigFromMap(cm)
if err != nil {
log.Fatalf("Error parsing logging configuration: %v", err)
log.Fatal("Error parsing logging configuration:", err)
}
logger, atomicLevel := logging.NewLoggerFromConfig(config, component)
defer logger.Sync()
Expand All @@ -79,7 +79,7 @@ func main() {
}

if err := version.CheckMinimumVersion(kubeClient.Discovery()); err != nil {
logger.Fatalf("Version check failed: %v", err)
logger.Fatalw("Version check failed", err)
}

// Watch the logging config map and dynamically update logging levels.
Expand Down