feat: add crashLoadGenerator

js/core/src/index.test.ts

@@ -442,7 +442,18 @@ const scn = scenario("scenario")
     (session) => true
   )
   .stopLoadGeneratorIf("#{message}", (session) => true)
-  .stopLoadGeneratorIf((session) => "message", "#{condition}");
+  .stopLoadGeneratorIf((session) => "message", "#{condition}")
+  // crashLoadGenerator
+  .crashLoadGenerator("#{message}")
+  .crashLoadGenerator((session) => "message")
+  // crashLoadGeneratorIf
+  .crashLoadGeneratorIf("#{message}", "#{condition}")
+  .crashLoadGeneratorIf(
+    (session) => "message",
+    (session) => true
+  )
+  .crashLoadGeneratorIf("#{message}", (session) => true)
+  .crashLoadGeneratorIf((session) => "message", "#{condition}");
 
 //registerPebbleExtensions((io.pebbletemplates.pebble.extension.Extension) null);
 

js/core/src/structure/errors.ts

@@ -127,6 +127,66 @@ export interface StopLoadGeneratorIfFunction<T extends Errors<T>> {
   (message: SessionTo<string>, condition: SessionTo<boolean>): T;
 }
 
+export interface CrashLoadGeneratorFunction<T extends Errors<T>> {
+  /**
+   * Have the virtual user abruptly stop the load generator with a failed status
+   *
+   * @param message - the message, expressed as a Gatling Expression Language String
+   * @returns a new StructureBuilder
+   */
+  (message: string): T;
+
+  /**
+   * Have the virtual user abruptly crash the load generator with a failed status
+   *
+   * @param message - the message, expressed as a function
+   * @returns a new StructureBuilder
+   */
+  (message: SessionTo<string>): T;
+}
+
+export interface CrashLoadGeneratorIfFunction<T extends Errors<T>> {
+  /**
+   * Have the virtual user abruptly crash the load generator with a failed status if a condition is
+   * met
+   *
+   * @param message - the message, expressed as a Gatling Expression Language String
+   * @param condition - the condition, expressed as a Gatling Expression Language String
+   * @returns a new StructureBuilder
+   */
+  (message: string, condition: string): T;
+
+  /**
+   * Have the virtual user abruptly crash the load generator with a failed status if a condition is
+   * met
+   *
+   * @param message - the message, expressed as a Gatling Expression Language String
+   * @param condition - the condition, expressed as a function
+   * @returns a new StructureBuilder
+   */
+  (message: string, condition: SessionTo<boolean>): T;
+
+  /**
+   * Have the virtual user abruptly crash the load generator with a failed status if a condition is
+   * met
+   *
+   * @param message - the message, expressed as a function
+   * @param condition - the condition, expressed as a Gatling Expression Language String
+   * @returns a new StructureBuilder
+   */
+  (message: SessionTo<string>, condition: string): T;
+
+  /**
+   * Have the virtual user abruptly crash the load generator with a failed status if a condition is
+   * met
+   *
+   * @param message - the message, expressed as a function
+   * @param condition - the condition, expressed as a function
+   * @returns a new StructureBuilder
+   */
+  (message: SessionTo<string>, condition: SessionTo<boolean>): T;
+}
+
 export interface Errors<T extends Errors<T>> {
   exitBlockOnFail: ExitBlockOnFailFunction<T>;
   tryMax: TryMaxFunction<T>;
@@ -135,6 +195,8 @@ export interface Errors<T extends Errors<T>> {
   exitHereIfFailed: ExitHereIfFailedFunction<T>;
   stopLoadGenerator: StopLoadGeneratorFunction<T>;
   stopLoadGeneratorIf: StopLoadGeneratorIfFunction<T>;
+  crashLoadGenerator: CrashLoadGeneratorFunction<T>;
+  crashLoadGeneratorIf: CrashLoadGeneratorIfFunction<T>;
 }
 
 export const errorsImpl = <J2, J1 extends JvmErrors<J2, any>, T extends Errors<T>>(
@@ -179,5 +241,26 @@ export const errorsImpl = <J2, J1 extends JvmErrors<J2, any>, T extends Errors<T
         return wrap(jvmErrors.stopLoadGeneratorIf(message, condition));
       }
     }
+  },
+  crashLoadGenerator: (message: string | SessionTo<string>): T =>
+    wrap(
+      typeof message === "function"
+        ? jvmErrors.crashLoadGenerator(underlyingSessionTo(message))
+        : jvmErrors.crashLoadGenerator(message)
+    ),
+  crashLoadGeneratorIf: (message: string | SessionTo<string>, condition: string | SessionTo<boolean>): T => {
+    if (typeof message === "function") {
+      if (typeof condition === "function") {
+        return wrap(jvmErrors.crashLoadGeneratorIf(underlyingSessionTo(message), underlyingSessionTo(condition)));
+      } else {
+        return wrap(jvmErrors.crashLoadGeneratorIf(underlyingSessionTo(message), condition));
+      }
+    } else {
+      if (typeof condition === "function") {
+        return wrap(jvmErrors.crashLoadGeneratorIf(message, underlyingSessionTo(condition)));
+      } else {
+        return wrap(jvmErrors.crashLoadGeneratorIf(message, condition));
+      }
+    }
   }
 });

js/core/src/structure/index.ts

@@ -126,3 +126,5 @@ export const exitHere = errorsImpl(JvmCoreDsl, wrapChainBuilder).exitHere;
 export const exitHereIfFailed = errorsImpl(JvmCoreDsl, wrapChainBuilder).exitHereIfFailed;
 export const stopLoadGenerator = errorsImpl(JvmCoreDsl, wrapChainBuilder).stopLoadGenerator;
 export const stopLoadGeneratorIf = errorsImpl(JvmCoreDsl, wrapChainBuilder).stopLoadGeneratorIf;
+export const crashLoadGenerator = errorsImpl(JvmCoreDsl, wrapChainBuilder).crashLoadGenerator;
+export const crashLoadGeneratorIf = errorsImpl(JvmCoreDsl, wrapChainBuilder).crashLoadGeneratorIf;

jvm/build.sbt

@@ -16,7 +16,7 @@ Global / gatlingDevelopers := Seq(
 val graalvmJdkVersion = "22.0.2"
 val graalvmJsVersion = "24.0.2"
 val coursierVersion = "2.1.10"
-val gatlingVersion = "3.12.0-SNAPSHOT"
+val gatlingVersion = "3.12.0"
 
 // bit weird cause this is not a dependency of this project
 val gatlingEnterpriseComponentPluginVersion = "1.9.6"