Remove classic mirror queues

rabbitmq · Nov 7, 2023 · 7eefe82 · 7eefe82
1 parent 9b6cb03
commit 7eefe82
Show file tree

Hide file tree

Showing 100 changed files with 286 additions and 11,367 deletions.
diff --git a/deps/rabbit/BUILD.bazel b/deps/rabbit/BUILD.bazel
@@ -87,9 +87,6 @@ _APP_ENV = """[
 	    {ssl_apps, [asn1, crypto, public_key, ssl]},
 	    %% classic queue storage implementation version
 	    {classic_queue_default_version, 2},
-	    %% see rabbitmq-server#114
-	    {mirroring_flow_control, true},
-	    {mirroring_sync_batch_size, 4096},
 	    %% see rabbitmq-server#227 and related tickets.
 	    %% msg_store_credit_disc_bound only takes effect when
 	    %% messages are persisted to the message store. If messages
@@ -395,7 +392,7 @@ rabbitmq_integration_suite(
     additional_beam = [
         ":test_queue_utils_beam",
     ],
-    shard_count = 7,
+    shard_count = 5,
 )
 
 rabbitmq_integration_suite(
@@ -421,17 +418,6 @@ rabbitmq_integration_suite(
     size = "medium",
 )
 
-rabbitmq_integration_suite(
-    name = "dynamic_ha_SUITE",
-    size = "large",
-    flaky = True,
-    shard_count = 20,
-    sharding_method = "case",
-    deps = [
-        "@proper//:erlang_app",
-    ],
-)
-
 rabbitmq_integration_suite(
     name = "dynamic_qq_SUITE",
     size = "large",
@@ -443,18 +429,6 @@ rabbitmq_integration_suite(
     ],
 )
 
-rabbitmq_integration_suite(
-    name = "eager_sync_SUITE",
-    size = "large",
-    additional_beam = [
-        ":sync_detection_SUITE_beam_files",
-    ],
-    flaky = True,
-    shard_count = 5,
-    sharding_method = "case",
-    tags = ["classic-queue"],
-)
-
 rabbitmq_integration_suite(
     name = "feature_flags_SUITE",
     size = "large",
@@ -522,15 +496,6 @@ rabbitmq_integration_suite(
     ],
 )
 
-rabbitmq_integration_suite(
-    name = "many_node_ha_SUITE",
-    size = "medium",
-    additional_beam = [
-        ":test_rabbit_ha_test_consumer_beam",
-        ":test_rabbit_ha_test_producer_beam",
-    ],
-)
-
 rabbitmq_integration_suite(
     name = "rabbit_message_interceptor_SUITE",
     size = "medium",
@@ -672,7 +637,7 @@ rabbitmq_integration_suite(
 rabbitmq_integration_suite(
     name = "queue_master_location_SUITE",
     size = "large",
-    shard_count = 3,
+    shard_count = 2,
 )
 
 rabbitmq_integration_suite(
@@ -681,7 +646,7 @@ rabbitmq_integration_suite(
     additional_beam = [
         ":test_queue_utils_beam",
     ],
-    shard_count = 6,
+    shard_count = 5,
 )
 
 rabbitmq_integration_suite(
@@ -862,16 +827,6 @@ rabbitmq_integration_suite(
     size = "medium",
 )
 
-rabbitmq_integration_suite(
-    name = "simple_ha_SUITE",
-    size = "large",
-    additional_beam = [
-        ":test_rabbit_ha_test_consumer_beam",
-        ":test_rabbit_ha_test_producer_beam",
-    ],
-    shard_count = 4,
-)
-
 rabbitmq_integration_suite(
     name = "single_active_consumer_SUITE",
     size = "medium",
@@ -880,11 +835,6 @@ rabbitmq_integration_suite(
     ],
 )
 
-rabbitmq_integration_suite(
-    name = "sync_detection_SUITE",
-    size = "medium",
-)
-
 rabbitmq_integration_suite(
     name = "term_to_binary_compat_prop_SUITE",
     deps = [
@@ -1001,15 +951,6 @@ rabbitmq_integration_suite(
     size = "medium",
 )
 
-rabbitmq_suite(
-    name = "unit_gm_SUITE",
-    size = "small",
-    deps = [
-        "//deps/rabbitmq_ct_helpers:erlang_app",
-        "@meck//:erlang_app",
-    ],
-)
-
 rabbitmq_integration_suite(
     name = "unit_log_management_SUITE",
     size = "medium",
@@ -1090,22 +1031,6 @@ rabbitmq_integration_suite(
     ],
 )
 
-rabbitmq_suite(
-    name = "unit_classic_mirrored_queue_sync_throttling_SUITE",
-    size = "small",
-    deps = [
-        "//deps/rabbit_common:erlang_app",
-    ],
-)
-
-rabbitmq_suite(
-    name = "unit_classic_mirrored_queue_throughput_SUITE",
-    size = "small",
-    deps = [
-        "//deps/rabbit_common:erlang_app",
-    ],
-)
-
 rabbitmq_integration_suite(
     name = "direct_exchange_routing_v2_SUITE",
     size = "medium",
@@ -1315,8 +1240,6 @@ eunit(
         ":test_rabbit_auth_backend_context_propagation_mock_beam",
         ":test_rabbit_dummy_protocol_connection_info_beam",
         ":test_rabbit_foo_protocol_connection_info_beam",
-        ":test_rabbit_ha_test_consumer_beam",
-        ":test_rabbit_ha_test_producer_beam",
         ":test_test_util_beam",
         ":test_test_rabbit_event_handler_beam",
         ":test_clustering_utils_beam",

diff --git a/deps/rabbit/Makefile b/deps/rabbit/Makefile
@@ -67,9 +67,6 @@ define PROJECT_ENV
 	    {ssl_apps, [asn1, crypto, public_key, ssl]},
 	    %% classic queue storage implementation version
 	    {classic_queue_default_version, 2},
-	    %% see rabbitmq-server#114
-	    {mirroring_flow_control, true},
-	    {mirroring_sync_batch_size, 4096},
 	    %% see rabbitmq-server#227 and related tickets.
 	    %% msg_store_credit_disc_bound only takes effect when
 	    %% messages are persisted to the message store. If messages