aboutsummaryrefslogtreecommitdiff
path: root/script/jepsen.garage/src/jepsen/garage.clj
diff options
context:
space:
mode:
authorAlex Auvolat <alex@adnab.me>2023-10-20 15:48:37 +0200
committerAlex Auvolat <alex@adnab.me>2023-10-20 15:48:37 +0200
commit654775308ed03abd68941b07b2ad367a4de5c57f (patch)
tree70c947029aba6b7fe40f286be2335b2db322c587 /script/jepsen.garage/src/jepsen/garage.clj
parentf5b09727815523a1bd4ba5f62d892b2b45b5bed6 (diff)
downloadgarage-654775308ed03abd68941b07b2ad367a4de5c57f.tar.gz
garage-654775308ed03abd68941b07b2ad367a4de5c57f.zip
jepsen: add cluster reconfiguration nemesis
Diffstat (limited to 'script/jepsen.garage/src/jepsen/garage.clj')
-rw-r--r--script/jepsen.garage/src/jepsen/garage.clj27
1 files changed, 13 insertions, 14 deletions
diff --git a/script/jepsen.garage/src/jepsen/garage.clj b/script/jepsen.garage/src/jepsen/garage.clj
index a566d9be..65a92a76 100644
--- a/script/jepsen.garage/src/jepsen/garage.clj
+++ b/script/jepsen.garage/src/jepsen/garage.clj
@@ -10,6 +10,7 @@
[jepsen.os.debian :as debian]
[jepsen.garage
[daemon :as grg]
+ [nemesis :as grgNemesis]
[reg :as reg]
[set :as set]]))
@@ -20,6 +21,11 @@
"set1" set/workload1
"set2" set/workload2})
+(def scenari
+ "A map of scenari to the associated nemesis"
+ {"cp" grgNemesis/scenario-cp
+ "r" grgNemesis/scenario-r})
+
(def patches
"A map of patch names to Garage builds"
{"default" "v0.9.0"
@@ -31,6 +37,9 @@
[["-p" "--patch NAME" "Garage patch to use"
:default "default"
:validate [patches (cli/one-of patches)]]
+ ["-s" "--scenario NAME" "Nemesis scenario to run"
+ :default "cp"
+ :validate [scenari (cli/one-of scenari)]]
["-r" "--rate HZ" "Approximate number of requests per second, per thread."
:default 10
:parse-fn read-string
@@ -40,7 +49,7 @@
:parse-fn parse-long
:validate [pos? "Must be a positive integer."]]
["-w" "--workload NAME" "Workload of test to run"
- :default "reg"
+ :default "reg1"
:validate [workloads (cli/one-of workloads)]]])
(defn garage-test
@@ -48,6 +57,7 @@
:concurrency, ...), constructs a test map."
[opts]
(let [workload ((get workloads (:workload opts)) opts)
+ scenario ((get scenari (:scenario opts)) opts)
garage-version (get patches (:patch opts))]
(merge tests/noop-test
opts
@@ -60,25 +70,14 @@
(->>
(:generator workload)
(gen/stagger (/ (:rate opts)))
- (gen/nemesis
- (cycle [(gen/sleep 5)
- {:type :info, :f :partition-start}
- (gen/sleep 5)
- {:type :info, :f :clock-scramble}
- (gen/sleep 5)
- {:type :info, :f :partition-stop}
- (gen/sleep 5)
- {:type :info, :f :clock-scramble}]))
+ (gen/nemesis (:generator scenario))
(gen/time-limit (:time-limit opts)))
(gen/log "Healing cluster")
(gen/nemesis (gen/once {:type :info, :f :partition-stop}))
(gen/log "Waiting for recovery")
(gen/sleep 10)
(gen/clients (:final-generator workload)))
- :nemesis (nemesis/compose
- {{:partition-start :start
- :partition-stop :stop} (nemesis/partition-random-halves)
- {:clock-scramble :scramble} (nemesis/clock-scrambler 20.0)})
+ :nemesis (:nemesis scenario)
:checker (checker/compose
{:perf (checker/perf)
:workload (:checker workload)})