From c6a992a01d2fd8d91103f16d9503d1e30784b32a Mon Sep 17 00:00:00 2001 From: Di Xu Date: Sun, 5 May 2019 19:26:13 +0800 Subject: [PATCH] add warning log for csr controllers --- cmd/kube-controller-manager/app/certificates.go | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/cmd/kube-controller-manager/app/certificates.go b/cmd/kube-controller-manager/app/certificates.go index 752e2c5a1bb..3ecf69e395f 100644 --- a/cmd/kube-controller-manager/app/certificates.go +++ b/cmd/kube-controller-manager/app/certificates.go @@ -39,7 +39,9 @@ import ( ) func startCSRSigningController(ctx ControllerContext) (http.Handler, bool, error) { - if !ctx.AvailableResources[schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"}] { + gvr := schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"} + if !ctx.AvailableResources[gvr] { + klog.Warningf("Resource %s is not available now", gvr.String()) return nil, false, nil } if ctx.ComponentConfig.CSRSigningController.ClusterSigningCertFile == "" || ctx.ComponentConfig.CSRSigningController.ClusterSigningKeyFile == "" { @@ -102,7 +104,9 @@ func startCSRSigningController(ctx ControllerContext) (http.Handler, bool, error } func startCSRApprovingController(ctx ControllerContext) (http.Handler, bool, error) { - if !ctx.AvailableResources[schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"}] { + gvr := schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"} + if !ctx.AvailableResources[gvr] { + klog.Warningf("Resource %s is not available now", gvr.String()) return nil, false, nil }