ShardCoordinator: misc cleanup (#7295)

akkadotnet · Jul 23, 2024 · 9eb670a · 9eb670a
1 parent a6daed7
commit 9eb670a
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/ClusterShardingGuardian.cs b/src/contrib/cluster/Akka.Cluster.Sharding/ClusterShardingGuardian.cs
@@ -179,7 +179,7 @@ public ClusterShardingGuardian(
                     {
                         // with the deprecated persistence state store mode we always use the event sourced provider for shard regions
                         // and no store for coordinator (the coordinator is a PersistentActor in that case)
-                        RememberEntitiesStore rememberEntitiesProvider =
+                        var rememberEntitiesProvider =
                           (settings.StateStoreMode == StateStoreMode.Persistence) ?
                             RememberEntitiesStore.Eventsourced : settings.RememberEntitiesStore;
 

diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/DDataShardCoordinator.cs b/src/contrib/cluster/Akka.Cluster.Sharding/DDataShardCoordinator.cs
@@ -123,7 +123,7 @@ public DDataShardCoordinator(
             else
                 _stateWriteConsistency = new WriteMajorityPlus(settings.TuningParameters.UpdatingStateTimeout, settings.TuningParameters.CoordinatorStateWriteMajorityPlus, majorityMinCap);
 
-            Cluster node = Cluster.Get(Context.System);
+            var node = Cluster.Get(Context.System);
             _selfUniqueAddress = node.SelfUniqueAddress;
 
             _coordinatorStateKey = new LWWRegisterKey<CoordinatorState>(typeName + "CoordinatorState");

diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/ShardCoordinator.cs b/src/contrib/cluster/Akka.Cluster.Sharding/ShardCoordinator.cs
@@ -1490,7 +1490,7 @@ public static Props Props(
 
             private ILoggingAdapter Log { get { return _log ??= Context.GetLogger(); } }
 
-            public ITimerScheduler Timers { get; set; }
+            public ITimerScheduler Timers { get; set; } = null!;
 
             /// <summary>
             /// TBD

diff --git a/src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs b/src/contrib/cluster/Akka.Cluster.Sharding/ShardRegion.cs
@@ -353,7 +353,7 @@ internal static Props Props(
             string coordinatorPath,
             IMessageExtractor messageExtractor,
             object handOffStopMessage,
-            IRememberEntitiesProvider rememberEntitiesProvider)
+            IRememberEntitiesProvider? rememberEntitiesProvider)
         {
             return Actor.Props.Create(() => new ShardRegion(
                     typeName,