]> Entropealabs - cluster_kv.git/commitdiff
revert json changes
authorChristopher <chris@entropealabs.com>
Sun, 8 Mar 2020 15:40:08 +0000 (10:40 -0500)
committerChristopher <chris@entropealabs.com>
Sun, 8 Mar 2020 15:40:08 +0000 (10:40 -0500)
priv/ring.json

index 21675f642d82274ce1fdd710b1527a0becaca65d..4a07b37c16c9b48fa0bf5acb11b27ec77c9ebd9f 100644 (file)
       "Type": "Choice",
       "Resource": "HandleReady",
       "Choices": [
+        {
+          "StringEquals": ":node_up",
+          "Next": "ReadyNodeUp"
+        },
+        {
+          "StringEquals": ":node_down",
+          "Next": "ReadyNodeDown"
+        },
         {
           "StringEquals": ":anti_entropy",
           "Next": "AntiEntropy"
       "InputPath": "",
       "OutputPath": ""
     },
+    "QuorumNodeUp": {
+      "Type": "Task",
+      "Resource": "HandleNodeUp",
+      "TransitionEvent": ":node_added",
+      "Catch": [],
+      "InputPath": "",
+      "OutputPath": "",
+      "ResourcePath": "",
+      "Next": "Quorum",
+      "End": false
+    },
+    "ReadyNodeUp": {
+      "Type": "Task",
+      "Resource": "HandleNodeUp",
+      "TransitionEvent": ":node_added",
+      "Catch": [],
+      "InputPath": "",
+      "OutputPath": "",
+      "ResourcePath": "",
+      "Next": "Ready",
+      "End": false
+    },
     "Quorum": {
       "Type": "Choice",
       "Resource": "AwaitQuorum",
         {
           "StringEquals": ":quorum",
           "Next": "Ready"
+        },
+        {
+          "StringEquals": ":node_up",
+          "Next": "QuorumNodeUp"
+        },
+        {
+          "StringEquals": ":node_down",
+          "Next": "QuorumNodeDown"
         }
       ],
       "InputPath": "",
       "OutputPath": ""
     },
+    "ReadyNodeDown": {
+      "Type": "Task",
+      "Resource": "HandleNodeDown",
+      "TransitionEvent": ":node_removed",
+      "Catch": [],
+      "InputPath": "",
+      "OutputPath": "",
+      "ResourcePath": "",
+      "Next": "Quorum",
+      "End": false
+    },
+    "QuorumNodeDown": {
+      "Type": "Task",
+      "Resource": "HandleNodeDown",
+      "TransitionEvent": ":node_removed",
+      "Catch": [],
+      "InputPath": "",
+      "OutputPath": "",
+      "ResourcePath": "",
+      "Next": "Quorum",
+      "End": false
+    },
     "AntiEntropy": {
       "Type": "Task",
       "Resource": "HandleAntiEntropy",