diff --git a/cmd/client/command/failover.go b/cmd/client/command/failover.go index ba869c56..2949a80b 100644 --- a/cmd/client/command/failover.go +++ b/cmd/client/command/failover.go @@ -84,6 +84,9 @@ func failoverShard(client *client, options *FailoverOptions, shardIndex int) err SetPathParam("namespace", options.namespace). SetPathParam("cluster", options.cluster). SetPathParam("shard", strconv.Itoa(shardIndex)). + SetBody(map[string]interface{}{ + "preferred_node_id": options.preferred, + }). Post("/namespaces/{namespace}/clusters/{cluster}/shards/{shard}/failover") if err != nil { return err