split brain resolver (#4587)

Co-authored-by: Aaron Stannard <aaron@petabridge.com>
akkadotnet · Feb 2, 2021 · 8360e41 · 8360e41
1 parent 9fe0da4
commit 8360e41
Show file tree

Hide file tree

Showing 14 changed files with 4,053 additions and 59 deletions.
diff --git a/src/core/Akka.API.Tests/CoreAPISpec.ApproveCluster.approved.txt b/src/core/Akka.API.Tests/CoreAPISpec.ApproveCluster.approved.txt
@@ -387,6 +387,51 @@ namespace Akka.Cluster.Routing
         public string UseRole { get; }
     }
 }
+namespace Akka.Cluster.SBR
+{
+    public sealed class KeepOldestSettings
+    {
+        public KeepOldestSettings(bool downIfAlone, string role) { }
+        public bool DownIfAlone { get; }
+        public string Role { get; }
+    }
+    public sealed class LeaseMajoritySettings
+    {
+        public LeaseMajoritySettings(string leaseImplementation, System.TimeSpan acquireLeaseDelayForMinority, string role) { }
+        public System.TimeSpan AcquireLeaseDelayForMinority { get; }
+        public string LeaseImplementation { get; }
+        public string Role { get; }
+    }
+    public class SplitBrainResolverProvider : Akka.Cluster.IDowningProvider
+    {
+        public SplitBrainResolverProvider(Akka.Actor.ActorSystem system) { }
+        public System.TimeSpan DownRemovalMargin { get; }
+        public Akka.Actor.Props DowningActorProps { get; }
+    }
+    public sealed class SplitBrainResolverSettings
+    {
+        public static readonly System.Collections.Immutable.ImmutableHashSet<string> AllStrategyNames;
+        public const string DownAllName = "down-all";
+        public const string KeepMajorityName = "keep-majority";
+        public const string KeepOldestName = "keep-oldest";
+        public const string LeaseMajorityName = "lease-majority";
+        public const string StaticQuorumName = "static-quorum";
+        public SplitBrainResolverSettings(Akka.Configuration.Config config) { }
+        public System.TimeSpan DownAllWhenUnstable { get; }
+        public System.TimeSpan DowningStableAfter { get; }
+        public string DowningStrategy { get; }
+        public string KeepMajorityRole { get; }
+        public Akka.Cluster.SBR.KeepOldestSettings KeepOldestSettings { get; }
+        public Akka.Cluster.SBR.LeaseMajoritySettings LeaseMajoritySettings { get; }
+        public Akka.Cluster.SBR.StaticQuorumSettings StaticQuorumSettings { get; }
+    }
+    public sealed class StaticQuorumSettings
+    {
+        public StaticQuorumSettings(int size, string role) { }
+        public string Role { get; }
+        public int Size { get; }
+    }
+}
 namespace Akka.Cluster.Serialization
 {
     public class ClusterMessageSerializer : Akka.Serialization.Serializer

diff --git a/src/core/Akka.API.Tests/CoreAPISpec.ApproveCoordination.approved.txt b/src/core/Akka.API.Tests/CoreAPISpec.ApproveCoordination.approved.txt
@@ -33,7 +33,6 @@ namespace Akka.Coordination
         public LeaseSettings(string leaseName, string ownerName, Akka.Coordination.TimeoutSettings timeoutSettings, Akka.Configuration.Config leaseConfig) { }
         public Akka.Configuration.Config LeaseConfig { get; }
         public string LeaseName { get; }
-        public System.Type LeaseType { get; }
         public string OwnerName { get; }
         public Akka.Coordination.TimeoutSettings TimeoutSettings { get; }
         public static Akka.Coordination.LeaseSettings Create(Akka.Configuration.Config config, string leaseName, string ownerName) { }

diff --git a/src/core/Akka.Cluster.Tests/Akka.Cluster.Tests.csproj b/src/core/Akka.Cluster.Tests/Akka.Cluster.Tests.csproj
@@ -8,6 +8,7 @@
   </PropertyGroup>
 
   <ItemGroup>
+    <ProjectReference Include="..\..\contrib\cluster\Akka.Cluster.Tools.Tests\Akka.Cluster.Tools.Tests.csproj" />
     <ProjectReference Include="..\Akka.Cluster\Akka.Cluster.csproj" />
     <ProjectReference Include="..\Akka.Tests.Shared.Internals\Akka.Tests.Shared.Internals.csproj" />
   </ItemGroup>