karmada-io
/
karmada
mirror of https://github.com/karmada-io/karmada.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

when UpdateOrCreateToken get secrets, if the error is not a NotFound, the error is thrown in time. 

Signed-off-by: helen <haitao.zhang@daocloud.io>
This commit is contained in:
helen 2023-01-11 01:00:53 +08:00
parent 07bb65bfe7
commit cc759c6706
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pkg/karmadactl/util/bootstraptoken/bootstraptoken.go
View File

@ -9,6 +9,7 @@ import (
"time"
corev1 "k8s.io/api/core/v1"
apierrors "k8s.io/apimachinery/pkg/api/errors"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/util/wait"
kubeclient "k8s.io/client-go/kubernetes"
@ -318,7 +319,10 @@ func CreateNewToken(client kubeclient.Interface, token *BootstrapToken) error {
func UpdateOrCreateToken(client kubeclient.Interface, failIfExists bool, token *BootstrapToken) error {
secretName := bootstraputil.BootstrapTokenSecretName(token.Token.ID)
secret, err := client.CoreV1().Secrets(metav1.NamespaceSystem).Get(context.TODO(), secretName, metav1.GetOptions{})
if secret != nil && err == nil && failIfExists {
if err != nil && !apierrors.IsNotFound(err) {
return err
}
if secret != nil && failIfExists {
return fmt.Errorf("a token with id %q already exists", token.Token.ID)
}