Deuxfleurs/garage
42
39
Fork 55
Code Issues 71 Pull requests 7 Releases 29 Wiki Activity

jepsen: code path for nemesis final generator
All checks were successful
continuous-integration/drone/push Build is passing
Details
continuous-integration/drone/pr Build is passing
Details

Browse source
This commit is contained in:
Alex 2023-10-20 15:53:46 +02:00
parent 654775308e
commit 9030c1eef8
2 changed files with 24 additions and 22 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
script/jepsen.garage/src/jepsen/garage.clj
View file

@ -73,7 +73,7 @@
(gen/nemesis (:generator scenario)) (gen/nemesis (:generator scenario))
(gen/time-limit (:time-limit opts))) (gen/time-limit (:time-limit opts)))
(gen/log "Healing cluster") (gen/log "Healing cluster")
(gen/nemesis (gen/once {:type :info, :f :partition-stop})) (gen/nemesis (:final-generator scenario))
(gen/log "Waiting for recovery") (gen/log "Waiting for recovery")
(gen/sleep 10) (gen/sleep 10)
(gen/clients (:final-generator workload))) (gen/clients (:final-generator workload)))

44
script/jepsen.garage/src/jepsen/garage/nemesis.clj
View file

@ -64,28 +64,30 @@
(defn scenario-cp (defn scenario-cp
"Clock scramble + parittion scenario" "Clock scramble + parittion scenario"
[opts] [opts]
{:generator (cycle [(gen/sleep 5) {:generator (cycle [(gen/sleep 5)
{:type :info, :f :partition-start} {:type :info, :f :partition-start}
(gen/sleep 5) (gen/sleep 5)
{:type :info, :f :clock-scramble} {:type :info, :f :clock-scramble}
(gen/sleep 5) (gen/sleep 5)
{:type :info, :f :partition-stop} {:type :info, :f :partition-stop}
(gen/sleep 5) (gen/sleep 5)
{:type :info, :f :clock-scramble}]) {:type :info, :f :clock-scramble}])
:nemesis (nemesis/compose :final-generator (gen/once {:type :info, :f :partition-stop})
{{:partition-start :start :nemesis (nemesis/compose
:partition-stop :stop} (nemesis/partition-random-halves) {{:partition-start :start
{:clock-scramble :scramble} (nemesis/clock-scrambler 20.0)})}) :partition-stop :stop} (nemesis/partition-random-halves)
{:clock-scramble :scramble} (nemesis/clock-scrambler 20.0)})})
(defn scenario-r (defn scenario-r
"Cluster reconfiguration scenario" "Cluster reconfiguration scenario"
[opts] [opts]
{:generator (cycle [(gen/sleep 5) {:generator (cycle [(gen/sleep 5)
{:type :info, :f :reconfigure-start} {:type :info, :f :reconfigure-start}
(gen/sleep 5) (gen/sleep 5)
{:type :info, :f :reconfigure-start} {:type :info, :f :reconfigure-start}
(gen/sleep 5) (gen/sleep 5)
{:type :info, :f :reconfigure-stop}]) {:type :info, :f :reconfigure-stop}])
:nemesis (nemesis/compose :final-generator (gen/once {:type :info, :f :reconfigure-stop})
{{:reconfigure-start :start :nemesis (nemesis/compose
:reconfigure-stop :stop} (reconfigure-subset 3)})}) {{:reconfigure-start :start
:reconfigure-stop :stop} (reconfigure-subset 3)})})