Send write operations to primary nodes only

Jepsen generate operations randomly for each node but in a Tarantool cluster
write operations (like INSERT, UPSERT etc) should be done only on a master
node.

Author: ligurio

src/tarantool/counter.clj

@@ -38,8 +38,9 @@
     (cl/with-error-handling op
       (cl/with-txn-aborts op
         (case (:f op)
-          :add (do (j/execute! conn
-                      [(str "UPDATE " table-name " SET count = count + ? WHERE id = 0") (:value op)])
+          :add (let [con (cl/open (jepsen/primary test) test)]
+                 (do (j/execute! con
+                      [(str "UPDATE " table-name " SET count = count + ? WHERE id = 0") (:value op)]))
                (assoc op :type :ok))
 
           :read (let [value (:COUNT

src/tarantool/sets.clj

@@ -6,6 +6,7 @@
                     [checker :as checker]
                     [generator :as gen]
                     [independent :as independent]]
+            [clojure.tools.logging :refer [info warn]]
             [next.jdbc :as j]
             [next.jdbc.sql :as sql]
             [tarantool.client :as cl]
@@ -37,8 +38,9 @@
     (cl/with-error-handling op
       (cl/with-txn-aborts op
         (case (:f op)
-          :add  (do (sql/insert! conn table-name {:value v})
-                    (assoc op :type :ok))
+          :add (let [con (cl/open (jepsen/primary test) test)]
+                 (do (sql/insert! con table-name {:value v})
+                    (assoc op :type :ok)))
 
           :read (->> (sql/query conn [(str "SELECT * FROM " table-name)])
                      (mapv :VALUE)