From 2dc8cadd00962512fa90c460b9fa86a175ca73fc Mon Sep 17 00:00:00 2001 From: lala123912 Date: Mon, 18 Jan 2021 17:19:32 +0800 Subject: [PATCH] staging/src/k8s.io/apiserver/pkg/admission: migrate to structured logs --- .../pkg/admission/plugin/namespace/lifecycle/admission.go | 5 +++-- .../pkg/admission/plugin/resourcequota/controller.go | 4 +++- .../apiserver/pkg/admission/plugin/webhook/object/matcher.go | 2 +- staging/src/k8s.io/apiserver/pkg/admission/plugins.go | 2 +- 4 files changed, 8 insertions(+), 5 deletions(-) diff --git a/staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go b/staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go index 0fac569c4f1..c417e3f98ae 100644 --- a/staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go +++ b/staging/src/k8s.io/apiserver/pkg/admission/plugin/namespace/lifecycle/admission.go @@ -140,7 +140,7 @@ func (l *Lifecycle) Admit(ctx context.Context, a admission.Attributes, o admissi exists = true } if exists { - klog.V(4).Infof("found %s in cache after waiting", a.GetNamespace()) + klog.V(4).InfoS("Namespace existed in cache after waiting", "namespace", klog.KRef("", a.GetNamespace())) } } @@ -161,7 +161,8 @@ func (l *Lifecycle) Admit(ctx context.Context, a admission.Attributes, o admissi case err != nil: return errors.NewInternalError(err) } - klog.V(4).Infof("found %s via storage lookup", a.GetNamespace()) + + klog.V(4).InfoS("Found namespace via storage lookup", "namespace", klog.KRef("", a.GetNamespace())) } // ensure that we're not trying to create objects in terminating namespaces diff --git a/staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go b/staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go index 51d3123eab3..8b0ab85a2f7 100644 --- a/staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go +++ b/staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go @@ -377,7 +377,7 @@ func getMatchedLimitedScopes(evaluator quota.Evaluator, inputObject runtime.Obje for _, limitedResource := range limitedResources { matched, err := evaluator.MatchingScopes(inputObject, limitedResource.MatchScopes) if err != nil { - klog.Errorf("Error while matching limited Scopes: %v", err) + klog.ErrorS(err, "Error while matching limited Scopes") return []corev1.ScopedResourceSelectorRequirement{}, err } for _, scope := range matched { @@ -449,6 +449,8 @@ func CheckRequest(quotas []corev1.ResourceQuota, a admission.Attributes, evaluat match, err := evaluator.Matches(&resourceQuota, inputObject) if err != nil { klog.Errorf("Error occurred while matching resource quota, %v, against input object. Err: %v", resourceQuota, err) + klog.ErrorS(err, "Error occurred while matching resource quota against input object", + "resourceQuota", resourceQuota) return quotas, err } if !match { diff --git a/staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/object/matcher.go b/staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/object/matcher.go index 773e3e6ee6d..0dccb5bb3ae 100644 --- a/staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/object/matcher.go +++ b/staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/object/matcher.go @@ -36,7 +36,7 @@ func matchObject(obj runtime.Object, selector labels.Selector) bool { } accessor, err := meta.Accessor(obj) if err != nil { - klog.V(5).Infof("cannot access metadata of %v: %v", obj, err) + klog.V(5).InfoS("Accessing metadata failed", "object", obj, "err", err) return false } return selector.Matches(labels.Set(accessor.GetLabels())) diff --git a/staging/src/k8s.io/apiserver/pkg/admission/plugins.go b/staging/src/k8s.io/apiserver/pkg/admission/plugins.go index e6da6f4a7fc..d720d9964e8 100644 --- a/staging/src/k8s.io/apiserver/pkg/admission/plugins.go +++ b/staging/src/k8s.io/apiserver/pkg/admission/plugins.go @@ -81,7 +81,7 @@ func (ps *Plugins) Register(name string, plugin Factory) { ps.registry = map[string]Factory{} } - klog.V(1).Infof("Registered admission plugin %q", name) + klog.V(1).InfoS("Registered admission plugin", "plugin", name) ps.registry[name] = plugin }