root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Respect RABBITMQ_METADATA_STORE in consistent hash exchange suite

This commit is contained in:
Michael Davis 2024-07-10 13:38:36 -04:00
parent 0a4e5a9845
commit da83358a4a
No known key found for this signature in database
1 changed files with 13 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
deps/rabbitmq_consistent_hash_exchange/test/rabbit_exchange_type_consistent_hash_SUITE.erl vendored
View File

@ -20,23 +20,17 @@
all() ->
[
{group, mnesia_store},
{group, khepri_store},
{group, routing_tests},
{group, hash_ring_management_tests},
{group, clustered},
{group, khepri_migration}
].
groups() ->
[
{mnesia_store, [], [
{routing_tests, [], routing_tests()},
{hash_ring_management_tests, [], hash_ring_management_tests()},
{clustered, [], [node_restart]}
]},
{khepri_store, [], [
{routing_tests, [], routing_tests()},
{hash_ring_management_tests, [], hash_ring_management_tests()},
{clustered, [], [node_restart]}
]},
{routing_tests, [], routing_tests()},
{hash_ring_management_tests, [], hash_ring_management_tests()},
{clustered, [], [node_restart]},
{khepri_migration, [], [
from_mnesia_to_khepri
]}
@ -82,14 +76,13 @@ init_per_suite(Config) ->
end_per_suite(Config) ->
rabbit_ct_helpers:run_teardown_steps(Config).
init_per_group(mnesia_store, Config) ->
rabbit_ct_helpers:set_config(Config, [{metadata_store, mnesia}]);
init_per_group(khepri_store, Config) ->
FFs = [khepri_db],
rabbit_ct_helpers:set_config(Config, [{metadata_store, {khepri, FFs}}]);
init_per_group(khepri_migration = Group, Config0) ->
Config = rabbit_ct_helpers:set_config(Config0, [{metadata_store, mnesia}]),
init_per_group(Group, Config, 1);
init_per_group(khepri_migration = Group, Config) ->
case rabbit_ct_broker_helpers:configured_metadata_store(Config) of
mnesia ->
init_per_group(Group, Config, 1);
_ ->
{skip, "This group only targets mnesia"}
end;
init_per_group(clustered = Group, Config) ->
init_per_group(Group, Config, 3);
init_per_group(Group, Config) ->
@ -105,12 +98,6 @@ init_per_group(Group, Config, NodesCount) ->
rabbit_ct_broker_helpers:setup_steps() ++
rabbit_ct_client_helpers:setup_steps()).
end_per_group(mnesia_store, Config) ->
Config;
end_per_group(khepri_store, Config) ->
Config;
end_per_group(khepri_migration, Config) ->
Config;
end_per_group(_, Config) ->
rabbit_ct_helpers:run_teardown_steps(Config,
rabbit_ct_client_helpers:teardown_steps() ++