github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-29 14:37:00 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #100877 from lojies/schedulerlogstructured

Browse Source 
Structured Logging migration: modify logs of kube-scheduler
This commit is contained in:
Kubernetes Prow Robot 2021-04-10 19:04:45 -07:00 committed by GitHub
commit 89056f66c8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/kube-scheduler/app/options/configfile.go
View File

@ -69,7 +69,7 @@ func LogOrWriteConfig(fileName string, cfg *kubeschedulerconfig.KubeSchedulerCon
return err return err
} }
configString := string(bytes) configString := string(bytes)
klog.Infof("Using component config:\n%+v\n", configString) klog.InfoS("Using component config", "config", configString)
} }
if len(fileName) > 0 { if len(fileName) > 0 {
@ -81,7 +81,7 @@ func LogOrWriteConfig(fileName string, cfg *kubeschedulerconfig.KubeSchedulerCon
if err := encoder.Encode(cfg, configFile); err != nil { if err := encoder.Encode(cfg, configFile); err != nil {
return err return err
} }
klog.Infof("Wrote configuration to: %s\n", fileName) klog.InfoS("Wrote configuration", "file", fileName)
os.Exit(0) os.Exit(0)
} }
return nil return nil

2
cmd/kube-scheduler/app/server.go
View File

@ -135,7 +135,7 @@ func runCommand(cmd *cobra.Command, opts *options.Options, registryOptions ...Op
// Run executes the scheduler based on the given configuration. It only returns on error or when context is done. // Run executes the scheduler based on the given configuration. It only returns on error or when context is done.
func Run(ctx context.Context, cc *schedulerserverconfig.CompletedConfig, sched *scheduler.Scheduler) error { func Run(ctx context.Context, cc *schedulerserverconfig.CompletedConfig, sched *scheduler.Scheduler) error {
// To help debugging, immediately log version // To help debugging, immediately log version
klog.V(1).Infof("Starting Kubernetes Scheduler version %+v", version.Get()) klog.V(1).InfoS("Starting Kubernetes Scheduler version", "version", version.Get())
// Configz registration. // Configz registration.
if cz, err := configz.New("componentconfig"); err == nil { if cz, err := configz.New("componentconfig"); err == nil {