From 4b7cff3a46ce5a8162dd3c5b497f4707023eefa3 Mon Sep 17 00:00:00 2001 From: Aaron Stannard Date: Mon, 22 Jul 2024 11:42:03 -0500 Subject: [PATCH] Akka.Cluster.Sharding: added tests for DData consistency settings (#7288) --- .../ClusterShardingConfigSpec.cs | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/src/contrib/cluster/Akka.Cluster.Sharding.Tests/ClusterShardingConfigSpec.cs b/src/contrib/cluster/Akka.Cluster.Sharding.Tests/ClusterShardingConfigSpec.cs index 303b1b03784..2986a1a8362 100644 --- a/src/contrib/cluster/Akka.Cluster.Sharding.Tests/ClusterShardingConfigSpec.cs +++ b/src/contrib/cluster/Akka.Cluster.Sharding.Tests/ClusterShardingConfigSpec.cs @@ -9,6 +9,7 @@ using Akka.Configuration; using Akka.TestKit; using Xunit; +using FluentAssertions; namespace Akka.Cluster.Sharding.Tests { @@ -30,6 +31,8 @@ public void Should_cluster_sharding_settings_have_default_config() ClusterSharding.Get(Sys); var config = Sys.Settings.Config.GetConfig("akka.cluster.sharding"); + var clusterShardingSettings = ClusterShardingSettings.Create(Sys); + Assert.False(config.IsNullOrEmpty()); Assert.Equal("sharding", config.GetString("guardian-name")); Assert.Equal(string.Empty, config.GetString("role")); @@ -64,6 +67,12 @@ public void Should_cluster_sharding_settings_have_default_config() Assert.Equal(string.Empty, singletonConfig.GetString("role")); Assert.Equal(TimeSpan.FromSeconds(1), singletonConfig.GetTimeSpan("hand-over-retry-interval")); Assert.Equal(15, singletonConfig.GetInt("min-number-of-hand-over-retries")); + + // DData settings + var minCap = config.GetInt("distributed-data.majority-min-cap"); + minCap.Should().Be(5); + clusterShardingSettings.TuningParameters.CoordinatorStateReadMajorityPlus.Should().Be(5); + clusterShardingSettings.TuningParameters.CoordinatorStateWriteMajorityPlus.Should().Be(3); } } }