Skip to content

Commit 193be96

Browse files
committed
Pod count should match shards + (shards*replicas)
1 parent 32cc1f4 commit 193be96

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

internal/controller/valkey_controller.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1623,7 +1623,7 @@ func (r *ValkeyReconciler) balanceNodes(ctx context.Context, valkey *hyperv1.Val
16231623
pods := map[string]string{}
16241624
var tries int
16251625
for {
1626-
if len(pods) != int(valkey.Spec.Shards) {
1626+
if len(pods) != int(valkey.Spec.Shards+valkey.Spec.Shards*valkey.Spec.Replicas) {
16271627
pods, err = r.getPodIPs(ctx, valkey)
16281628
if err != nil {
16291629
logger.Error(err, "failed to get pod ips")

0 commit comments

Comments
 (0)