WIP

Signed-off-by: Derek Su <derek.su@suse.com>
longhorn · Jun 4, 2024 · bc19699 · bc19699
1 parent 762d26a
commit bc19699
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git a/pkg/client/instance.go b/pkg/client/instance.go
@@ -89,6 +89,8 @@ func NewInstanceServiceClientWithTLS(ctx context.Context, ctxCancel context.Canc
 type EngineCreateRequest struct {
 	ReplicaAddressMap map[string]string
 	Frontend          string
+	InitiatorIP       string
+	TargetIP          string
 	UpgradeRequired   bool
 }
 
@@ -190,6 +192,8 @@ func (c *InstanceServiceClient) InstanceCreate(req *InstanceCreateRequest) (*api
 
 			UpgradeRequired: req.Engine.UpgradeRequired,
 			TargetAddress:   uri.Hostname(),
+			InitiatorIp:     req.Engine.InitiatorIP,
+			TargetIp:        req.Engine.TargetIP,
 		},
 	})
 	if err != nil {

diff --git a/pkg/instance/instance.go b/pkg/instance/instance.go
@@ -153,7 +153,7 @@ func (ops V2DataEngineInstanceOps) InstanceCreate(req *rpc.InstanceCreateRequest
 	switch req.Spec.Type {
 	case types.InstanceTypeEngine:
 		engine, err := c.EngineCreate(req.Spec.Name, req.Spec.VolumeName, req.Spec.SpdkInstanceSpec.Frontend, req.Spec.SpdkInstanceSpec.Size, req.Spec.SpdkInstanceSpec.ReplicaAddressMap,
-			req.Spec.PortCount, req.Spec.UpgradeRequired, req.Spec.TargetAddress)
+			req.Spec.PortCount, req.Spec.UpgradeRequired, req.Spec.TargetAddress, req.Spec.InitiatorIp, req.Spec.TargetIp)
 		if err != nil {
 			return nil, err
 		}