From 0749315d7eae55e500d9f643d0d8dff3eaedac65 Mon Sep 17 00:00:00 2001 From: Humble Chirammal Date: Wed, 23 Jun 2021 13:06:12 +0530 Subject: [PATCH] e2e: make use of snapshot v1 api in utils.go Signed-off-by: Humble Chirammal --- e2e/utils.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/e2e/utils.go b/e2e/utils.go index f4b99cb52..21cde15dd 100644 --- a/e2e/utils.go +++ b/e2e/utils.go @@ -12,7 +12,7 @@ import ( "sync" "time" - "github.com/kubernetes-csi/external-snapshotter/v2/pkg/apis/volumesnapshot/v1beta1" + snapapi "github.com/kubernetes-csi/external-snapshotter/client/v4/apis/volumesnapshot/v1" v1 "k8s.io/api/core/v1" scv1 "k8s.io/api/storage/v1" "k8s.io/apimachinery/pkg/api/resource" @@ -718,7 +718,7 @@ func validatePVCSnapshot(totalCount int, pvcPath, appPath, snapshotPath, pvcClon snap.Spec.Source.PersistentVolumeClaimName = &pvc.Name // create snapshot for i := 0; i < totalCount; i++ { - go func(w *sync.WaitGroup, n int, s v1beta1.VolumeSnapshot) { + go func(w *sync.WaitGroup, n int, s snapapi.VolumeSnapshot) { s.Name = fmt.Sprintf("%s%d", f.UniqueName, n) wgErrs[n] = createSnapshot(&s, deployTimeout) if wgErrs[n] == nil && kms != "" { @@ -890,9 +890,9 @@ func validatePVCSnapshot(totalCount int, pvcPath, appPath, snapshotPath, pvcClon wg.Add(totalCount) // delete snapshot for i := 0; i < totalCount; i++ { - go func(w *sync.WaitGroup, n int, s v1beta1.VolumeSnapshot) { + go func(w *sync.WaitGroup, n int, s snapapi.VolumeSnapshot) { s.Name = fmt.Sprintf("%s%d", f.UniqueName, n) - content := &v1beta1.VolumeSnapshotContent{} + content := &snapapi.VolumeSnapshotContent{} var err error if kms != "" { if kmsIsVault(kms) || kms == vaultTokens {