diff --git a/state_transfer/transfer/blockrsync/client.go b/state_transfer/transfer/blockrsync/client.go index 6622a91..e095426 100644 --- 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 index 9e2e338..9293a1d 100644 --- 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 {