raftNodeInstance.IsLeader(optional parameter entityName) will help to…

… understand either node is a Leader or not
hhblaze · Oct 17, 2019 · 54b17ce · 54b17ce
1 parent a875681
commit 54b17ce
Show file tree

Hide file tree

Showing 11 changed files with 68 additions and 8 deletions.
diff --git a/Deployment/!!!Raft.nuspec b/Deployment/!!!Raft.nuspec
@@ -2,7 +2,7 @@
 <package xmlns="http://schemas.microsoft.com/packaging/2011/08/nuspec.xsd">
     <metadata>
         <id>Raft</id>
-        <version>1.5.1</version>
+        <version>1.6</version>
         <title>Raft.NET dotnet consensus algorithm implementation</title>
         <authors>Alex Solovyov</authors>
         <owners>tiesky.com / Alex Solovyov</owners>
@@ -11,7 +11,7 @@
         <requireLicenseAcceptance>false</requireLicenseAcceptance>
         <description>Implementation of the RAFT consensus algorithm among TCP peers with disk or memory persistence</description>
         <summary>Raft.NET dotnet consensus algorithm implementation</summary>
-        <releaseNotes>raftNodeInstance.NodeIsInLatestState can help to understand if started node is in the latest update state</releaseNotes>
+        <releaseNotes>raftNodeInstance.IsLeader(optional parameter entityName) will help to understand either node is a Leader or not</releaseNotes>
         <copyright>Copyright © 2018 tiesky.com / Alex Solovyov</copyright>
         <language>es-US</language>
         <tags>RAFT Raft.NET dotnet dbreeze netcore netstandard net framework</tags>

diff --git a/Deployment/Raft.1.6.0.nupkg b/Deployment/Raft.1.6.0.nupkg
diff --git a/Raft/RaftNode.cs b/Raft/RaftNode.cs
@@ -176,13 +176,22 @@ public void Dispose()
             //}
         }
 
-
-
-
         /// <summary>
-        /// We need this value to calculate majority while leader election
+        /// Is node a leader
         /// </summary>
-        public void SetNodesQuantityInTheCluster(uint nodesQuantityInTheCluster)
+        public bool IsLeader
+        {
+            get
+            {
+                return this.NodeState == eNodeState.Leader;
+            }
+        }
+
+
+    /// <summary>
+    /// We need this value to calculate majority while leader election
+    /// </summary>
+    public void SetNodesQuantityInTheCluster(uint nodesQuantityInTheCluster)
         {
             lock (lock_Operations)
             {
@@ -1321,7 +1330,7 @@ internal void Commited()
             });            
         }
 
-
+      
         public void EmulationStop()
         {
             this.NodeStop();

diff --git a/Raft/Transport/TcpRaftNode.cs b/Raft/Transport/TcpRaftNode.cs
@@ -119,6 +119,21 @@ public TcpRaftNode(NodeSettings nodeSettings, string dbreezePath, Func<string, u
             }
         }
 
+        /// <summary>
+        /// Gets raft node by entity and returns if it is a leader 
+        /// </summary>
+        /// <param name="entityName"></param>
+        /// <returns></returns>
+        public bool IsLeader(string entityName = "default")
+        {
+            if(this.raftNodes.TryGetValue(entityName, out var rn))
+            {
+                return rn.IsLeader;
+            }
+
+            return false;
+        }
+
         /// <summary>
         /// 
         /// </summary>

diff --git a/Raft/bin/Release-NET47/Raft.dll b/Raft/bin/Release-NET47/Raft.dll
diff --git a/Raft/bin/Release-NET47/Raft.pdb b/Raft/bin/Release-NET47/Raft.pdb
diff --git a/Raft/bin/Release-NET47/Raft.xml b/Raft/bin/Release-NET47/Raft.xml
diff --git a/Raft/bin/Release/Raft.dll b/Raft/bin/Release/Raft.dll
diff --git a/Raft/bin/Release/Raft.xml b/Raft/bin/Release/Raft.xml
diff --git a/RaftStandard/bin/Release/netstandard2.0/Raft.dll b/RaftStandard/bin/Release/netstandard2.0/Raft.dll
diff --git a/RaftStandard/bin/Release/netstandard2.0/Raft.xml b/RaftStandard/bin/Release/netstandard2.0/Raft.xml