From 5ba7790b261aaf0a2801ab794ea7731131bc3f4e Mon Sep 17 00:00:00 2001 From: Humble Chirammal Date: Wed, 23 Jun 2021 13:01:36 +0530 Subject: [PATCH] e2e: make use of snapshot v1 api in rbd_helper.go Signed-off-by: Humble Chirammal --- e2e/rbd_helper.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/e2e/rbd_helper.go b/e2e/rbd_helper.go index a84b2e885..051a444bd 100644 --- a/e2e/rbd_helper.go +++ b/e2e/rbd_helper.go @@ -10,7 +10,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" @@ -270,7 +270,7 @@ func validateCloneInDifferentPool(f *framework.Framework, snapshotPool, cloneSc, 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) w.Done() @@ -357,7 +357,7 @@ func validateCloneInDifferentPool(f *framework.Framework, snapshotPool, cloneSc, 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) wgErrs[n] = deleteSnapshot(&s, deployTimeout) w.Done()