feat: pass DstReplicaSrcReplicaPairMap in proxy SnapshotClone

And bump proxy API version to 7

Longhorn 12552

Signed-off-by: Shuo Wu <shuo.wu@suse.com>

Author: shuo-wu

pkg/client/proxy_snapshot.go

@@ -133,7 +133,7 @@ func (c *ProxyClient) SnapshotList(dataEngine, engineName, volumeName,
 
 func (c *ProxyClient) SnapshotClone(dataEngine, engineName, volumeName, serviceAddress,
 	snapshotName, fromEngineAddress, fromVolumeName, fromEngineName string, fileSyncHTTPClientTimeout int,
-	grpcTimeoutSeconds int64, cloneMode string) (err error) {
+	grpcTimeoutSeconds int64, cloneMode string, dstReplicaSrcReplicaPairMap map[string]string) (err error) {
 	input := map[string]string{
 		"engineName":        engineName,
 		"volumeName":        volumeName,
@@ -166,14 +166,15 @@ func (c *ProxyClient) SnapshotClone(dataEngine, engineName, volumeName, serviceA
 			DataEngine:         rpc.DataEngine(driver),
 			VolumeName:         volumeName,
 		},
-		FromEngineAddress:         fromEngineAddress,
-		SnapshotName:              snapshotName,
-		ExportBackingImageIfExist: false,
-		FileSyncHttpClientTimeout: int32(fileSyncHTTPClientTimeout),
-		FromEngineName:            fromEngineName,
-		FromVolumeName:            fromVolumeName,
-		GrpcTimeoutSeconds:        grpcTimeoutSeconds,
-		CloneMode:                 getCloneMode(cloneMode),
+		FromEngineAddress:           fromEngineAddress,
+		SnapshotName:                snapshotName,
+		ExportBackingImageIfExist:   false,
+		FileSyncHttpClientTimeout:   int32(fileSyncHTTPClientTimeout),
+		FromEngineName:              fromEngineName,
+		FromVolumeName:              fromVolumeName,
+		GrpcTimeoutSeconds:          grpcTimeoutSeconds,
+		CloneMode:                   getCloneMode(cloneMode),
+		DstReplicaSrcReplicaPairMap: dstReplicaSrcReplicaPairMap,
 	}
 	ctx, cancel := getContextWithGRPCLongTimeout(c.ctx, grpcTimeoutSeconds)
 	defer cancel()

pkg/meta/version.go

@@ -6,7 +6,7 @@ const (
 	InstanceManagerAPIMinVersion = 1
 
 	// InstanceManagerProxyAPIVersion is used for compatibility check for longhorn-manager
-	InstanceManagerProxyAPIVersion    = 6
+	InstanceManagerProxyAPIVersion    = 7
 	InstanceManagerProxyAPIMinVersion = 1
 
 	// InstanceManagerDiskServiceAPIVersion used to communicate with the user e.g. longhorn-manager

pkg/proxy/snapshot.go

@@ -290,7 +290,7 @@ func (ops V2DataEngineProxyOps) SnapshotClone(ctx context.Context, req *rpc.Engi
 		}
 	}()
 
-	err = c.EngineSnapshotClone(req.ProxyEngineRequest.EngineName, req.SnapshotName, req.FromEngineName, req.FromEngineAddress, spdkrpc.CloneMode(req.CloneMode))
+	err = c.EngineSnapshotClone(req.ProxyEngineRequest.EngineName, req.SnapshotName, req.FromEngineName, req.FromEngineAddress, spdkrpc.CloneMode(req.CloneMode), req.DstReplicaSrcReplicaPairMap)
 	if err != nil {
 		return nil, grpcstatus.Errorf(grpccodes.Internal, "failed to do clone snapshot %v: %v", req.SnapshotName, err)
 	}