fix(tests): slow down cluster migration test for fast hardware

The TestClusterReset test was failing on macOS ARM because the slot
migration completed before the test could observe the "start" state.

Reduce migrate-speed from 128 to 64 and increase data size from 1024
to 2048 elements to ensure the migration takes long enough to observe
intermediate states on fast hardware (~32 seconds vs ~8 seconds).

Author: ethervoid

tests/gocase/integration/cluster/cluster_test.go

@@ -574,9 +574,10 @@ func TestClusterReset(t *testing.T) {
 
 	t.Run("cannot reset cluster if the db is migrating the slot", func(t *testing.T) {
 		slotNum := 2
-		// slow down the migration speed to avoid breaking other test cases
-		require.NoError(t, rdb0.ConfigSet(ctx, "migrate-speed", "128").Err())
-		for i := 0; i < 1024; i++ {
+		// slow down the migration speed to ensure we can observe the "start" state
+		// before migration completes (especially on fast hardware like macOS ARM)
+		require.NoError(t, rdb0.ConfigSet(ctx, "migrate-speed", "64").Err())
+		for i := 0; i < 2048; i++ {
 			require.NoError(t, rdb0.RPush(ctx, "my-list", fmt.Sprintf("element%d", i)).Err())
 		}
 

tests/gocase/integration/replication/slow_consumer_bug_test.go

@@ -175,7 +175,7 @@ func TestSlowConsumerBlocksIndefinitely(t *testing.T) {
 	//
 	// For this test, we use low values to see the fix in action quickly
 	master := util.StartServer(t, map[string]string{
-		"max-replication-lag":         "50",  // Very low: disconnect when lag > 50 sequences
+		"max-replication-lag":         "50",   // Very low: disconnect when lag > 50 sequences
 		"replication-send-timeout-ms": "3000", // 3 second timeout
 	})
 	defer master.Close()

tests/gocase/util/client.go

@@ -202,7 +202,7 @@ func PausableTCPProxy(ctx context.Context, t testing.TB, to string, pauseCh <-ch
 
 					// Set read deadline to allow checking pause state periodically
 					if conn, ok := src.(net.Conn); ok {
-						conn.SetReadDeadline(time.Now().Add(200 * time.Millisecond))
+						_ = conn.SetReadDeadline(time.Now().Add(200 * time.Millisecond))
 					}
 
 					n, err := src.Read(buffer)
@@ -237,7 +237,7 @@ func PausableTCPProxy(ctx context.Context, t testing.TB, to string, pauseCh <-ch
 				break LISTEN_LOOP
 
 			default:
-				listener.(*net.TCPListener).SetDeadline(time.Now().Add(100 * time.Millisecond))
+				_ = listener.(*net.TCPListener).SetDeadline(time.Now().Add(100 * time.Millisecond))
 				conn, err := listener.Accept()
 				if err != nil {
 					if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
@@ -259,7 +259,7 @@ func PausableTCPProxy(ctx context.Context, t testing.TB, to string, pauseCh <-ch
 					// "to_master" = reading from slave (conn), writing to master (dest)
 					errGrp.Go(copyBytes(dest, conn, "to_slave"))
 					errGrp.Go(copyBytes(conn, dest, "to_master"))
-					errGrp.Wait()
+					_ = errGrp.Wait()
 					conn.Close()
 					dest.Close()
 				}()