Skip to content

Commit

Permalink
Remove classic mirror queues
Browse files Browse the repository at this point in the history
  • Loading branch information
dcorbacho committed Oct 31, 2023
1 parent 9b6cb03 commit 75221e5
Show file tree
Hide file tree
Showing 100 changed files with 299 additions and 11,284 deletions.
83 changes: 3 additions & 80 deletions deps/rabbit/BUILD.bazel
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down Expand Up @@ -395,7 +392,7 @@ rabbitmq_integration_suite(
additional_beam = [
":test_queue_utils_beam",
],
shard_count = 7,
shard_count = 5,
)

rabbitmq_integration_suite(
Expand All @@ -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",
Expand All @@ -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",
Expand Down Expand Up @@ -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",
Expand Down Expand Up @@ -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(
Expand All @@ -681,7 +646,7 @@ rabbitmq_integration_suite(
additional_beam = [
":test_queue_utils_beam",
],
shard_count = 6,
shard_count = 5,
)

rabbitmq_integration_suite(
Expand Down Expand Up @@ -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",
Expand All @@ -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 = [
Expand Down Expand Up @@ -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",
Expand Down Expand Up @@ -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",
Expand Down Expand Up @@ -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",
Expand Down
3 changes: 0 additions & 3 deletions deps/rabbit/Makefile
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Loading

0 comments on commit 75221e5

Please sign in to comment.