feat(lib): add crashes to InjectFaults

platonic-io · Jan 11, 2021 · a5fab2c · a5fab2c
1 parent 561ab93
commit a5fab2c
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/src/lib/scheduler.go b/src/lib/scheduler.go
@@ -56,11 +56,15 @@ func InjectFaults(faults Faults) {
 		var schedulerFault SchedulerFault
 		switch ev := fault.Args.(type) {
 		case Omission:
-			//assert fault.Kind?
 			schedulerFault.Kind = fault.Kind
 			schedulerFault.From = ev.From
 			schedulerFault.To = ev.To
 			schedulerFault.At = ev.At // convert?
+		case Crash:
+			schedulerFault.Kind = fault.Kind
+			schedulerFault.From = ev.From
+			schedulerFault.To = ""    // Not used.
+			schedulerFault.At = ev.At // convert?
 		default:
 			panic(fmt.Sprintf("Unknown fault type: %#v\n", fault))
 		}