UPSTREAM: <carry>: emit event when readyz goes true

OpenShift-Rebase-Source: 6386eb2
openshift · Nov 3, 2023 · 100ea91 · 100ea91
1 parent 58eb6a7
commit 100ea91
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 0 deletions.
diff --git a/pkg/controlplane/controller/kubernetesservice/controller.go b/pkg/controlplane/controller/kubernetesservice/controller.go
@@ -151,6 +151,8 @@ func (c *Controller) Run(ch <-chan struct{}) {
 		return code == http.StatusOK, nil
 	}, ch)
 
+	KubeAPIServerEmitEventFn(corev1.EventTypeWarning, "KubeAPIReadyz", "readyz=true")
+
 	wait.NonSlidingUntil(func() {
 		// Service definition is not reconciled after first
 		// run, ports and type will be corrected only during

diff --git a/pkg/controlplane/controller/kubernetesservice/patch.go b/pkg/controlplane/controller/kubernetesservice/patch.go
@@ -0,0 +1,5 @@
+package kubernetesservice
+
+var KubeAPIServerEmitEventFn EventSinkFunc = nil
+
+type EventSinkFunc func(eventType, reason, messageFmt string, args ...interface{})
diff --git a/pkg/controlplane/instance.go b/pkg/controlplane/instance.go
@@ -413,6 +413,7 @@ func (c completedConfig) New(delegationTarget genericapiserver.DelegationTarget)
 		GenericAPIServer:          s,
 		ClusterAuthenticationInfo: c.ExtraConfig.ClusterAuthenticationInfo,
 	}
+	kubernetesservice.KubeAPIServerEmitEventFn = m.GenericAPIServer.Eventf
 
 	clientset, err := kubernetes.NewForConfig(c.GenericConfig.LoopbackClientConfig)
 	if err != nil {