diff options
Diffstat (limited to 'storage/src/tests/distributor/distributor_stripe_test_util.cpp')
| -rw-r--r-- | storage/src/tests/distributor/distributor_stripe_test_util.cpp | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/storage/src/tests/distributor/distributor_stripe_test_util.cpp b/storage/src/tests/distributor/distributor_stripe_test_util.cpp index 0605099e09b..9e87aa08cfa 100644 --- a/storage/src/tests/distributor/distributor_stripe_test_util.cpp +++ b/storage/src/tests/distributor/distributor_stripe_test_util.cpp @@ -102,6 +102,14 @@ DistributorStripeTestUtil::set_redundancy(uint32_t redundancy) _stripe->propagateDefaultDistribution(std::move(distribution)); } +void +DistributorStripeTestUtil::trigger_distribution_change(lib::Distribution::SP distr) +{ + _node->getComponentRegister().setDistribution(distr); + auto new_config = BucketSpaceDistributionConfigs::from_default_distribution(distr); + _stripe->update_distribution_config(new_config); +} + std::shared_ptr<DistributorConfiguration> DistributorStripeTestUtil::make_config() const { |