summaryrefslogtreecommitdiff
path: root/edge
diff options
context:
space:
mode:
Diffstat (limited to 'edge')
-rw-r--r--edge/pkg/edged/kubeclientbridge/typed/core/v1/serviceaccount_bridge.go6
-rw-r--r--edge/pkg/metamanager/client/serviceaccount.go2
2 files changed, 7 insertions, 1 deletions
diff --git a/edge/pkg/edged/kubeclientbridge/typed/core/v1/serviceaccount_bridge.go b/edge/pkg/edged/kubeclientbridge/typed/core/v1/serviceaccount_bridge.go
index 4f39c94f7..278f1c0a1 100644
--- a/edge/pkg/edged/kubeclientbridge/typed/core/v1/serviceaccount_bridge.go
+++ b/edge/pkg/edged/kubeclientbridge/typed/core/v1/serviceaccount_bridge.go
@@ -28,6 +28,7 @@ import (
authenticationv1 "k8s.io/api/authentication/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+ "k8s.io/apimachinery/pkg/types"
fakecorev1 "k8s.io/client-go/kubernetes/typed/core/v1/fake"
"github.com/kubeedge/kubeedge/edge/pkg/metamanager/client"
@@ -44,3 +45,8 @@ type ServiceAccountsBridge struct {
func (c *ServiceAccountsBridge) CreateToken(ctx context.Context, serviceAccountName string, tokenRequest *authenticationv1.TokenRequest, opts metav1.CreateOptions) (result *authenticationv1.TokenRequest, err error) {
return c.MetaClient.ServiceAccountToken().GetServiceAccountToken(c.ns, serviceAccountName, tokenRequest)
}
+
+func (c *ServiceAccountsBridge) Delete(ctx context.Context, podUID string, opts metav1.DeleteOptions) error {
+ c.MetaClient.ServiceAccountToken().DeleteServiceAccountToken(types.UID(podUID))
+ return nil
+}
diff --git a/edge/pkg/metamanager/client/serviceaccount.go b/edge/pkg/metamanager/client/serviceaccount.go
index 0323fab40..121a64c43 100644
--- a/edge/pkg/metamanager/client/serviceaccount.go
+++ b/edge/pkg/metamanager/client/serviceaccount.go
@@ -48,7 +48,7 @@ func (c *serviceAccountToken) DeleteServiceAccountToken(podUID types.UID) {
for _, sa := range *svcAccounts {
var tr authenticationv1.TokenRequest
err = json.Unmarshal([]byte(sa.Value), &tr)
- if err != nil {
+ if err != nil || tr.Spec.BoundObjectRef == nil {
klog.Errorf("unmarshal resource %s token request failed: %v", sa.Key, err)
continue
}