add groupversion field in the args

kanisterio · Aug 30, 2023 · 9a03a5d · 9a03a5d
1 parent 0af2e9d
commit 9a03a5d
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pkg/kube/volume/volume.go b/pkg/kube/volume/volume.go
@@ -116,6 +116,7 @@ type CreatePVCFromSnapshotArgs struct {
 	Annotations      map[string]string
 	VolumeMode       *v1.PersistentVolumeMode
 	AccessModes      []v1.PersistentVolumeAccessMode
+	APIGroupVersion  *metav1.GroupVersion
 }
 
 // CreatePVCFromSnapshot will restore a volume and returns the resulting
@@ -131,6 +132,10 @@ func CreatePVCFromSnapshot(ctx context.Context, args *CreatePVCFromSnapshotArgs)
 	}
 	snapshotKind := "VolumeSnapshot"
 	snapshotAPIGroup := "snapshot.storage.k8s.io"
+	if args.APIGroupVersion != nil {
+		snapshotAPIGroup = args.APIGroupVersion.String()
+	}
+
 	pvc := &v1.PersistentVolumeClaim{
 		ObjectMeta: metav1.ObjectMeta{
 			Labels:      args.Labels,