Configure ramp up time

Author: jmarin

build.sbt

@@ -67,7 +67,7 @@ lazy val cluster = (project in file("cluster"))
     )
   )
   .dependsOn(
-    modelJVM,
+    modelJVM % "compile->compile;test->test",
     parserJVM,
     apiModel,
     api,

cluster/src/test/resources/application.conf

@@ -4,6 +4,7 @@ hmda {
     host = ${?HMDA_BENCHMARK_HOST}
     port = "8080"
     port = ${?HMDA_BENCHMARK_PORT}
-    nrOfUsers = 500
+    nrOfUsers = 5
+    rampUpTime = 10
   }
 }

cluster/src/test/scala/api/http/benchmark/FilingSimulation.scala

@@ -1,18 +1,23 @@
 package api.http.benchmark
 
 import com.typesafe.config.ConfigFactory
+import hmda.api.protocol.admin.WriteInstitutionProtocol
+import hmda.model.institution.Institution
 import io.gatling.core.Predef._
 import io.gatling.http.Predef._
 
 import scala.concurrent.duration._
 import scala.language.postfixOps
+import spray.json._
+import hmda.model.institution.InstitutionGenerators._
 
-class FilingSimulation extends Simulation {
+class FilingSimulation extends Simulation with WriteInstitutionProtocol {
 
   val config = ConfigFactory.load()
   val host = config.getString("hmda.benchmark.host")
   val port = config.getInt("hmda.benchmark.port")
   val nrOfUsers = config.getInt("hmda.benchmark.nrOfUsers")
+  val rampUpTime = config.getInt("hmda.benchmark.rampUpTime")
 
   val institutionIds = (1 to nrOfUsers).toList
 
@@ -25,15 +30,21 @@ class FilingSimulation extends Simulation {
     .userAgentHeader("Mozilla/5.0 (Macintosh; Intel Mac OS X 10.8; rv:16.0) Gecko/20100101 Firefox/16.0")
     .header("cfpb-hmda-username", "user")
     .header("cfpb-hmda-institutions", institutionIds.mkString(","))
+    .disableCaching
 
   val filingScenario = scenario("HMDA Filing")
     .exec(http("GET Institutions")
       .get("/institutions")
       .check(
         status is 200
       ))
+  //.pause(1)
+  //    .exec(http("POST Institutions")
+  //      .post("/institutions")
+  //      //.post(Institution.empty.toJson.toString()).asJSON
+  //      .check(status is 201))
 
   setUp(filingScenario.inject(
-    constantUsersPerSec(2) during (10 seconds)
+    rampUsers(nrOfUsers) over (rampUpTime seconds)
   ).protocols(httpProtocol))
 }