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

allow to shutdown quickly the apiserver

Browse Source
This commit is contained in:
Antonio Ojea
2024-06-19 17:14:59 +00:00
parent 418f98aae4
commit 7c4726d016
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/controlplane/controller/kubernetesservice/controller.go
View File

@@ -145,11 +145,15 @@ func (c *Controller) Stop() {
// Run periodically updates the kubernetes service // Run periodically updates the kubernetes service
func (c *Controller) Run(ch <-chan struct{}) { func (c *Controller) Run(ch <-chan struct{}) {
// wait until process is ready // wait until process is ready
wait.PollImmediateUntil(100*time.Millisecond, func() (bool, error) { ctx := wait.ContextForChannel(ch)
err := wait.PollUntilContextCancel(ctx, 100*time.Millisecond, true, func(context.Context) (bool, error) {
var code int var code int
c.client.CoreV1().RESTClient().Get().AbsPath("/readyz").Do(context.TODO()).StatusCode(&code) c.client.CoreV1().RESTClient().Get().AbsPath("/readyz").Do(context.TODO()).StatusCode(&code)
return code == http.StatusOK, nil return code == http.StatusOK, nil
}, ch) })
if err != nil {
return
}
wait.NonSlidingUntil(func() { wait.NonSlidingUntil(func() {
// Service definition is not reconciled after first // Service definition is not reconciled after first