From f3d400730e3ec184cfe981e396beb626f5adea70 Mon Sep 17 00:00:00 2001 From: Humble Chirammal Date: Wed, 23 Jun 2021 13:03:59 +0530 Subject: [PATCH] e2e: make use of snapshot v1 api in cephfs.go The import name of snapshot api package has also been changed from `vs` to `snapapi` for consistency. Signed-off-by: Humble Chirammal --- e2e/cephfs.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/e2e/cephfs.go b/e2e/cephfs.go index 634953c40..84dd612e3 100644 --- a/e2e/cephfs.go +++ b/e2e/cephfs.go @@ -8,7 +8,7 @@ import ( "strings" "sync" - vs "github.com/kubernetes-csi/external-snapshotter/v2/pkg/apis/volumesnapshot/v1beta1" + snapapi "github.com/kubernetes-csi/external-snapshotter/client/v4/apis/volumesnapshot/v1" . "github.com/onsi/ginkgo" // nolint v1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" @@ -788,7 +788,7 @@ var _ = Describe("cephfs", func() { snap.Spec.Source.PersistentVolumeClaimName = &pvc.Name // create snapshot for i := 0; i < totalCount; i++ { - go func(w *sync.WaitGroup, n int, s vs.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() @@ -911,7 +911,7 @@ var _ = Describe("cephfs", func() { wg.Add(totalCount) // delete snapshot for i := 0; i < totalCount; i++ { - go func(w *sync.WaitGroup, n int, s vs.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()