Allow nodeName to be set in blockrsync options (#125)

If the source volume is RWO we need to ensure the blockrsync client is started on the same node as the running pod. This change allows the nodeName to be set in the blockrsync options. Signed-off-by: Alexander Wels <[email protected]>
migtools · Aug 5, 2024 · 005b344 · 005b344
1 parent d53911c
commit 005b344
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/state_transfer/transfer/blockrsync/client.go b/state_transfer/transfer/blockrsync/client.go
@@ -97,6 +97,9 @@ func createBlockrsyncClient(c client.Client, r *BlockrsyncTransfer, pvc transfer
 			RestartPolicy: v1.RestartPolicyOnFailure,
 		},
 	}
+	if r.transferOptions.NodeName != "" {
+		pod.Spec.NodeName = r.transferOptions.NodeName
+	}
 
 	return c.Create(context.TODO(), &pod, &client.CreateOptions{})
 }

diff --git a/state_transfer/transfer/blockrsync/options.go b/state_transfer/transfer/blockrsync/options.go
@@ -9,6 +9,7 @@ type TransferOptions struct {
 	password              string
 	blockrsyncServerImage string
 	blockrsyncClientImage string
+	NodeName              string
 }
 
 func (t *TransferOptions) GetBlockrsyncServerImage() string {