Skip to content

Commit 4f917a0

Browse files
authored
Merge pull request kubernetes#77467 from dixudx/csrsigning_controller_warning
add warning logs for csr controllers
2 parents 437b967 + c6a992a commit 4f917a0

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

cmd/kube-controller-manager/app/certificates.go

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,9 @@ import (
3939
)
4040

4141
func startCSRSigningController(ctx ControllerContext) (http.Handler, bool, error) {
42-
if !ctx.AvailableResources[schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"}] {
42+
gvr := schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"}
43+
if !ctx.AvailableResources[gvr] {
44+
klog.Warningf("Resource %s is not available now", gvr.String())
4345
return nil, false, nil
4446
}
4547
if ctx.ComponentConfig.CSRSigningController.ClusterSigningCertFile == "" || ctx.ComponentConfig.CSRSigningController.ClusterSigningKeyFile == "" {
@@ -102,7 +104,9 @@ func startCSRSigningController(ctx ControllerContext) (http.Handler, bool, error
102104
}
103105

104106
func startCSRApprovingController(ctx ControllerContext) (http.Handler, bool, error) {
105-
if !ctx.AvailableResources[schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"}] {
107+
gvr := schema.GroupVersionResource{Group: "certificates.k8s.io", Version: "v1beta1", Resource: "certificatesigningrequests"}
108+
if !ctx.AvailableResources[gvr] {
109+
klog.Warningf("Resource %s is not available now", gvr.String())
106110
return nil, false, nil
107111
}
108112

0 commit comments

Comments
 (0)