mirror of
https://github.com/siderolabs/talos.git
synced 2025-10-08 14:11:13 +02:00
085c61b2ec
The problem is that the kubelet kubeconfig gets created early, but the actual client key and cert files are not written, so controllers spam with scary errors that the config is not valid. This PR removes those scary messages as we wait for the kubeconfig to be usable. Signed-off-by: Andrey Smirnov <andrey.smirnov@talos-systems.com>
57 lines
1.2 KiB
Go
57 lines
1.2 KiB
Go
// This Source Code Form is subject to the terms of the Mozilla Public
|
|
// License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
// file, You can obtain one at http://mozilla.org/MPL/2.0/.
|
|
|
|
package conditions
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"time"
|
|
)
|
|
|
|
type file string
|
|
|
|
func (filename file) Wait(ctx context.Context) error {
|
|
ticker := time.NewTicker(time.Second)
|
|
defer ticker.Stop()
|
|
|
|
for {
|
|
_, err := os.Stat(string(filename))
|
|
if err == nil {
|
|
return nil
|
|
}
|
|
|
|
if !os.IsNotExist(err) {
|
|
return err
|
|
}
|
|
|
|
select {
|
|
case <-ctx.Done():
|
|
return ctx.Err()
|
|
case <-ticker.C:
|
|
}
|
|
}
|
|
}
|
|
|
|
func (filename file) String() string {
|
|
return fmt.Sprintf("file %q to exist", string(filename))
|
|
}
|
|
|
|
// WaitForFileToExist is a service condition that will wait for the existence of
|
|
// a file.
|
|
func WaitForFileToExist(filename string) Condition {
|
|
return file(filename)
|
|
}
|
|
|
|
// WaitForFilesToExist is a service condition that will wait for the existence of all the files.
|
|
func WaitForFilesToExist(filenames ...string) Condition {
|
|
conditions := make([]Condition, len(filenames))
|
|
for i := range filenames {
|
|
conditions[i] = WaitForFileToExist(filenames[i])
|
|
}
|
|
|
|
return WaitForAll(conditions...)
|
|
}
|