Signed-off-by: Hiroshi Muraoka <h.muraoka714@gmail.com>
@@ -35,6 +35,7 @@ func NewTokenSource(ctx context.Context, auth esv1beta1.GCPSMAuth, projectID str
if err != nil {
return nil, fmt.Errorf("unable to initialize workload identity")
}
+ defer wi.Close()
ts, err = wi.TokenSource(ctx, auth, isClusterKind, kube, namespace)
if ts != nil || err != nil {
return ts, err
@@ -78,11 +78,11 @@ type saTokenGenerator interface {
func newWorkloadIdentity(ctx context.Context, projectID string) (*workloadIdentity, error) {
- iamc, err := newIAMClient(ctx)
+ satg, err := newSATokenGenerator()
return nil, err
- satg, err := newSATokenGenerator()
+ iamc, err := newIAMClient(ctx)