mirrors/talos
1
0
Fork 0
mirror of https://github.com/siderolabs/talos.git synced 2025-10-12 16:11:10 +02:00
Code Issues Packages Projects Releases Wiki Activity

feat: Add retry on get kubeconfig

Browse Source 
This implement retry when get kubeconfig

Signed-off-by: Sekerin Evgeniy <sekerin.e.a@gmail.com>
This commit is contained in:
Sekerin Evgeniy 2019-10-24 02:26:55 +05:00 committed by Andrew Rynhard
parent 457c6416a6
commit c6e1e6f28f
1 changed files with 17 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
internal/app/osd/internal/reg/reg.go
View File

@ -15,6 +15,7 @@ import (
"path/filepath"
"strings"
"syscall"
"time"
criconstants "github.com/containerd/cri/pkg/constants"
"github.com/golang/protobuf/ptypes/empty"
@ -29,6 +30,7 @@ import (
"github.com/talos-systems/talos/pkg/chunker"
filechunker "github.com/talos-systems/talos/pkg/chunker/file"
"github.com/talos-systems/talos/pkg/constants"
"github.com/talos-systems/talos/pkg/retry"
)
// Registrator is the concrete type that implements the factory.Registrator and
@ -42,7 +44,21 @@ func (r *Registrator) Register(s *grpc.Server) {
// Kubeconfig implements the osapi.OSDServer interface.
func (r *Registrator) Kubeconfig(ctx context.Context, in *empty.Empty) (data *osapi.DataReply, err error) {
fileBytes, err := ioutil.ReadFile(constants.AdminKubeconfig)
var fileBytes []byte
err = retry.Constant(5*time.Minute, retry.WithUnits(5*time.Second)).Retry(func() error {
fileBytes, err = ioutil.ReadFile(constants.AdminKubeconfig)
if err != nil {
if os.IsNotExist(err) {
return retry.ExpectedError(err)
}
return retry.UnexpectedError(err)
}
return nil
})
if err != nil {
return
}