Enable using Raft consensus in a cluster

Closes #42

Author: ligurio

resources/tarantool/jepsen.lua

@@ -13,7 +13,7 @@ else
 box.cfg {
     listen = 3301;
     replication = { %TARANTOOL_REPLICATION% };
-    read_only = %TARANTOOL_IS_READ_ONLY%;
+    --read_only = %TARANTOOL_IS_READ_ONLY%;
     replication_synchro_quorum = 2;
     replication_synchro_timeout = 0.2;
     log_level = 6;

src/tarantool/client.clj

@@ -22,6 +22,25 @@
     :connectTimeout (/ max-timeout 1000)
     :socketTimeout (/ max-timeout 1000)})
 
+;(defn is-read-only
+;  [conn]
+;  (j/execute! conn ["SELECT lua('return box.info().ro') IS NOT NULL"]))
+
+;(defn set-read-only-mode
+;  "Disable and enable read only mode"
+;  [conn mode]
+;  (j/execute! conn ["SELECT LUA('box.cfg{read_only=true}; return true')"]))
+
+(defn is-primary?
+  [test node]
+  (let [conn (cl/open node test)]
+    (if (= node p) true false)))
+  j/query conn ["box.info.election.state"]
+
+(defn primary
+  [nodes]
+  (doseq [n nodes] (println n))
+
 (defn open
   "Opens a connection to the given node."
   [node test]

src/tarantool/db.clj

@@ -2,8 +2,9 @@
   (:require [clojure.tools.logging :refer :all]
             [clojure.string :as str]
             [clojure.java.io :as io]
-            [next.jdbc :as j]
-            [next.jdbc.connection :as connection]
+            ;[next.jdbc :as j]
+            ;[next.jdbc.connection :as connection]
+            [tarantool.client :as cl]
             [jepsen.os.debian :as debian]
             [jepsen.control.util :as cu]
             [jepsen [core :as jepsen]
@@ -191,11 +192,6 @@
   [b]
   (if (true? b) "true" "false"))
 
-(defn is-primary?
-  [test node]
-  (let [p (jepsen/primary test)]
-    (if (= node p) true false)))
-
 (defn is-single-mode?
   [test]
   (let [n (count (:nodes test))]
@@ -206,27 +202,17 @@
 (defn configure!
   "Configure instance"
   [test node]
-  (let [read-only (not (is-primary? test node))]
-    (info "Joining" node "as" (if (true? read-only) "replica" "leader"))
-    (c/exec :mkdir :-p "/etc/tarantool/instances.available")
-    (c/exec :mkdir :-p "/etc/tarantool/instances.enabled")
-    (c/exec :usermod :-a :-G :tarantool :ubuntu)
-    (c/exec :echo (-> "tarantool/jepsen.lua" io/resource slurp
-                      (str/replace #"%TARANTOOL_REPLICATION%" (replica-set test))
-                      (str/replace #"%TARANTOOL_IS_READ_ONLY%" (boolean-to-str read-only))
-                      (str/replace #"%TARANTOOL_SINGLE_MODE%" (boolean-to-str (is-single-mode? test)))
-                      (str/replace #"%TARANTOOL_DATA_ENGINE%" (:engine test)))
-            :> "/etc/tarantool/instances.enabled/jepsen.lua")
-    (c/exec :cp "/etc/tarantool/instances.enabled/jepsen.lua" "/etc/tarantool/instances.available")))
-
-(defn is-read-only
-  [conn]
-  (j/execute! conn ["SELECT lua('return box.info().ro') IS NOT NULL"]))
-
-(defn set-read-only-mode
-  "Disable and enable read only mode"
-  [conn mode]
-  (j/execute! conn ["SELECT LUA('box.cfg{read_only=true}; return true')"]))
+  (info "Joining" node "as" (if (true? read-only) "replica" "leader"))
+  (c/exec :mkdir :-p "/etc/tarantool/instances.available")
+  (c/exec :mkdir :-p "/etc/tarantool/instances.enabled")
+  (c/exec :usermod :-a :-G :tarantool :ubuntu)
+  (c/exec :echo (-> "tarantool/jepsen.lua" io/resource slurp
+                    (str/replace #"%TARANTOOL_REPLICATION%" (replica-set test))
+                    ;(str/replace #"%TARANTOOL_IS_READ_ONLY%" (boolean-to-str read-only))
+                    (str/replace #"%TARANTOOL_SINGLE_MODE%" (boolean-to-str (is-single-mode? test)))
+                    (str/replace #"%TARANTOOL_DATA_ENGINE%" (:engine test)))
+          :> "/etc/tarantool/instances.enabled/jepsen.lua")
+  (c/exec :cp "/etc/tarantool/instances.enabled/jepsen.lua" "/etc/tarantool/instances.available"))
 
 (defn db
   "Tarantool DB for a particular version."