diff options
author | 2022-06-27 09:32:27 -0400 | |
---|---|---|
committer | 2022-06-27 09:32:27 -0400 | |
commit | 8263637ec9d7d5928c56f76817f91940d460a7da (patch) | |
tree | d23e92a6dbff9aa9989ca57314d7c1b0fc8b5b46 /gatling/ONAP single API 2022.scala | |
parent | 713c56b8d0f64fe411a6833240c10c44c8c33eb7 (diff) |
[AAI] Update the gatling scripts to have proper structure, pom, and readme
Issue-ID: AAI-3505
Signed-off-by: wr148d <wr148d@att.com>
Change-Id: I031dd436c1fc10d92640937c4a777e653e961926
Diffstat (limited to 'gatling/ONAP single API 2022.scala')
-rw-r--r-- | gatling/ONAP single API 2022.scala | 754 |
1 files changed, 0 insertions, 754 deletions
diff --git a/gatling/ONAP single API 2022.scala b/gatling/ONAP single API 2022.scala deleted file mode 100644 index c0ab5c7..0000000 --- a/gatling/ONAP single API 2022.scala +++ /dev/null @@ -1,754 +0,0 @@ -import io.gatling.core.Predef.{exec, _} -import io.gatling.http.Predef._ -import _root_.io.gatling.core.scenario.Simulation -import java.util.UUID -import scala.concurrent.duration._ - -import scala.util.Random - -class ONAP_2204_SingleAPI extends Simulation { - - val httpHeaders = Map( - "Accept" -> """application/json""", - "Content-Type"-> """application/json""", - "X-FromAppId"-> """ONAP-fromappId""", - "X-TransactionId"-> """ONAP-transId""", - "Connection"-> """Keep-Alive""" - ) - - def idGenerator() = "random-" + UUID.randomUUID().toString; - val feeder = Iterator.continually(Map("randVal" -> (Random.alphanumeric.take(20).mkString))) - - val tenantFeeder = csv("./src/test/gatling/bodies/onaptenants.csv").random - val LogLinkFeeder = csv("./src/test/gatling/bodies/onaploglinks.csv").random - val PServerFeeder = csv("./src/test/gatling/bodies/onappservers.csv").random - val serviceInstanceFeeder = csv("./src/test/gatling/bodies/onapserviceinstance.csv").random - val genericvnfFeeder = csv("./src/test/gatling/bodies/onapvnfs.csv").random - val CloudRegionFeeder = csv("./src/test/gatling/bodies/onapcloudregions.csv").random - val ComplexFeeder = csv("./src/test/gatling/bodies/onapcomplexes.csv").random - val customerFeeder = csv("./src/test/gatling/bodies/onapcustomers.csv").random - val vfmoduleFeeder = csv("./src/test/gatling/bodies/onapvf-modules.csv").random - val pnfFeeder = csv("./src/test/gatling/bodies/onappnfs.csv").random - - - - - - val host = System.getProperty("TARGET_HOST", "Enter Host with Port"); - - val httpBuilder = http.baseURL(host); - - def SingleAPITest(env: String) = scenario("Run each API single-user " + env) - - /*** - * - * @param env - * @PUT tenant - */ -.repeat(3){ - exec(session => { - session.set("stenant", idGenerator()) - }) - .exec( - http("PutTenant " + env) - .put("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner4/onap-CRId4/tenants/tenant/${stenant}") - .body(ElFileBody("newtenant_valid.json")) - .headers(httpHeaders) - .check( - status.find.in(201) - ) - ) - .pause(1,1) - .exec( - http("GetTenant " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner4/onap-CRId4/tenants/tenant/${stenant}") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check(jsonPath("$.resource-version").saveAs("resourcever")) - ) - .exec( - http("DeleteTenant " + env) - .delete("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner4/onap-CRId4/tenants/tenant/${stenant}?resource-version=${resourcever}") - .headers(httpHeaders) - .check(status.find.in(204)) - ) - - } - - /*** - * - * @param env - * @patch tenant - */ -.repeat(3){ - // Get the resource version before doing the PATCH - feed(tenantFeeder) - .exec( - http("GetTenant " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner/onap-CRId/tenants/tenant/onap-tenant-patch") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check( - jsonPath("$.resource-version").saveAs("rsrcver") - ) - ) - - .exec( - http("PatchTenant " + env) - .patch("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner/onap-CRId/tenants/tenant/onap-tenant-patch?resource-version=${rsrcver}") - .headers(httpHeaders) - .headers(Map( - "Content-Type"-> """application/merge-patch+json""" - )) - .body(ElFileBody("patch-tenant.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get tenant depth=0 - */ -.repeat(3){ - feed(tenantFeeder) - .exec( - http("GetTenantdepth0 " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner3/onap-CRId3/tenants/tenant/onap-tenantId3?depth=0") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get vserver-depth=all - */ - .repeat(3){ - exec( - http("GetVserverdepthall " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner2/onap-CRId2/tenants/tenant/onap-tenantId2/vservers/vserver/onap-vserverId2?depth=all") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get vserver - */ - .repeat(3){ - exec( - http("GetVserver " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner2/onap-CRId2/tenants/tenant/onap-tenantId2/vservers/vserver/onap-vserverId2") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get gen-vnf - */ - .repeat(3){ - feed(genericvnfFeeder) - .exec( - http("GetVnf " + env) - .get("/aai/v23/network/generic-vnfs/generic-vnf/${vnf-id}") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get gen-vnf depth=1 - */ - .repeat(3){ - feed(genericvnfFeeder) - .exec( - http("GetVnfdepth1 " + env) - .get("/aai/v23/network/generic-vnfs/generic-vnf/${vnf-id}?depth=1") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get vf-module depth=1 - */ - .repeat(3){ - feed(vfmoduleFeeder) - .exec( - http("GetVfmoduledepthl " + env) - .get("/aai/v23/network/generic-vnfs/generic-vnf/onap-genericvnfId/vf-modules/vf-module/onap-vnfmoduleId?depth=1") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @put vf-module - */ - .repeat(3){ - feed(genericvnfFeeder) - exec(session => { - session.set("svfmodule", idGenerator()) - }) - .exec( - http("PutVfmodule " + env) - .put("/aai/v23/network/generic-vnfs/generic-vnf/onap-genericvnfId/vf-modules/vf-module/${svfmodule}") - .body(ElFileBody("newvf-module_valid.json")) - .headers(httpHeaders) - .check( - status.find.in(201) - ) - ) - .pause(1,1) - .exec( - http("GetVfmodule " + env) - .get("/aai/v23/network/generic-vnfs/generic-vnf/onap-genericvnfId/vf-modules/vf-module/${svfmodule}") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check(jsonPath("$.resource-version").saveAs("resourcever")) - ) -.pause(1,1) - .exec( - http("DeleteVfmodule " + env) - .delete("/aai/v23/network/generic-vnfs/generic-vnf/onap-genericvnfId/vf-modules/vf-module/${svfmodule}?resource-version=${resourcever}") - .headers(httpHeaders) - .check(status.find.in(204)) - ) -.pause(1,1) - - } - - /*** - * - * @param env - * @patch/post vf-module - */ - .repeat(3){ - // Get the resource version before doing the PATCH - feed(vfmoduleFeeder) - .exec( - http("GetVfmodule " + env) - .get("/aai/v23/network/generic-vnfs/generic-vnf/onap-genericvnfId/vf-modules/vf-module/onap-vnfmoduleId") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check( - jsonPath("$.resource-version").saveAs("rsrcver") - ) - ) - - .exec( - http("PatchVfmodule " + env) - .patch("/aai/v23/network/generic-vnfs/generic-vnf/onap-genericvnfId/vf-modules/vf-module/onap-vnfmoduleId?resource-version=${rsrcver}") - .headers(httpHeaders) - .headers(Map( - "Content-Type"-> """application/merge-patch+json""" - )) - .body(ElFileBody("patch-vf-module.json")) - .check( - status.find.in(200) - ) - ) - - } - - /*** - * - * @param env - * @get recents api vlan - */ - .repeat(3){ - exec( - http("GetRecentsAPI Vlan " + env) - .get("/aai/recents/v23/vlan?hours=192") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get recents api l-interface - */ - .repeat(3){ - exec( - http("GetRecentsAPI l-interface " + env) - .get("/aai/recents/v23/l-interface?hours=192") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get recents api vserver - */ - .repeat(3){ - exec( - http("GetRecentsAPI vserver " + env) - .get("/aai/recents/v23/vserver?hours=192") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get all CRs1 - */ - .repeat(3){ - exec( - http("GetallCR onap-CRId " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/?cloud-region-id=onap-CRId") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get all CRs2 - */ - .repeat(3){ - exec( - http("GetallCR onap-CRId " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/?cloud-region-id=onap-CRId") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get all services - */ - .repeat(3){ - exec( - http("GetallServices " + env) - .get("/aai/v23/service-design-and-creation/services") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get all CRs - */ - .repeat(3){ - exec( - http("GetallCRs " + env) - .get("/aai/v23/cloud-infrastructure/cloud-regions/?cloud-region-id=onap-CRId") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @get nodes-query - */ - .repeat(3){ - exec( - http("Getnodes-query VNF " + env) - .get("/aai/v23/search/nodes-query?search-node-type=generic-vnf&filter=vnf-name:EQUALS:onap-genericvnfname") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @PUT singletx1 - */ - .feed(tenantFeeder) - .repeat(3){ - exec(session => { - session.set("sPServer", idGenerator()) - }) - .exec(session => { - session.set("sVServer", idGenerator()) - }) - .exec( - http("BulkSingleTx1 " + env) - .post("/aai/v22/bulk/single-transaction") - .body(ElFileBody("onapbulk-single-tx_putPServerVServer.json")) - .headers(httpHeaders) - .check( - status.find.in(201) - ) - ) - .pause(2,33) - .exec( - http("GetVserver " + env) - .get("/aai/v22/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner/onap-CRId/tenants/tenant/onap-tenantId1/vservers/vserver/${sVServer}?depth=0&nodes-only=true") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check(jsonPath("$.resource-version").saveAs("rsrcver")) - ) - .exec( - http("DeleteVserver " + env) - .delete("/aai/v22/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner/onap-CRId/tenants/tenant/onap-tenantId1/vservers/vserver/${sVServer}?resource-version=${rsrcver}") - .headers(httpHeaders) - - .check(status.find.in(204)) - ) - .exec( - http("GetPserver " + env) - .get("/aai/v22/cloud-infrastructure/pservers/pserver/${sPServer}?depth=0&nodes-only=true") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check(jsonPath("$.resource-version").saveAs("rsrcver")) - ) - .exec( - http("DeletePserver " + env) - .delete("/aai/v22/cloud-infrastructure/pservers/pserver/${sPServer}?resource-version=${rsrcver}") - .headers(httpHeaders) - .check(status.find.in(204)) - ) - .pause(1,1) - } - - - /*** - * - * @param env - * @PUT bulksingletx2 - */ - .repeat(3){ - exec(session => { - session.set("CR1", idGenerator()) - }) - .exec(session => { - session.set("AZ1", idGenerator()) - }) - .exec(session => { - session.set("flavor1", idGenerator()) - }) - .exec(session => { - session.set("image1", idGenerator()) - }) - .exec(session => { - session.set("complex1", idGenerator()) - }) - .exec(session => { - session.set("pserver1", idGenerator()) - }) - .exec(session => { - session.set("pserver2", idGenerator()) - }) - .exec(session => { - session.set("pserver3", idGenerator()) - }) - .exec( - http("BulkSingleTx2 " + env) - .post("/aai/v21/bulk/single-transaction") - .body(ElFileBody("onap-patch-bulk-single-tx.json")) - .headers(httpHeaders) - .check( - status.find.in(201) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @PUT bulksingletx3 - */ - .feed(tenantFeeder) - .repeat(3){ - exec(session => { - session.set("sPServer", idGenerator()) - }) - .exec(session => { - session.set("sVServer", idGenerator()) - }) - .exec( - http("BulkSingleTx3 " + env) - .post("/aai/v22/bulk/single-transaction") - .body(ElFileBody("onapbulk-single-tx_putPServerVServer.json")) - .headers(httpHeaders) - .check( - status.find.in(201) - ) - ) - .pause(2,5) - .exec( - http("GetVserver " + env) - .get("/aai/v22/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner/onap-CRId/tenants/tenant/onap-tenantId1/vservers/vserver/${sVServer}?depth=0&nodes-only=true") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check(jsonPath("$.resource-version").saveAs("rsrcver")) - ) - .exec( - http("DeleteVserver " + env) - .delete("/aai/v22/cloud-infrastructure/cloud-regions/cloud-region/onap-CROwner/onap-CRId/tenants/tenant/onap-tenantId1/vservers/vserver/${sVServer}?resource-version=${rsrcver}") - .headers(httpHeaders) - - .check(status.find.in(204)) - ) - .exec( - http("GetPserver " + env) - .get("/aai/v22/cloud-infrastructure/pservers/pserver/${sPServer}?depth=0&nodes-only=true") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - .check(jsonPath("$.resource-version").saveAs("rsrcver")) - ) - .exec( - http("DeletePserver " + env) - .delete("/aai/v22/cloud-infrastructure/pservers/pserver/${sPServer}?resource-version=${rsrcver}") - .headers(httpHeaders) - .check(status.find.in(204)) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @CQ pserverzdeviceresurldepth1 - */ - .repeat(3){ - exec( - http("CQ pserverzdeviceresurldepth1 " + env) - .put("/aai/v22/query?format=resource_and_url&depth=1") - .headers(httpHeaders) - .body(ElFileBody("onap-CQ-pserver-zdevice.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @CQ pserverzdeviceres - */ - .repeat(3){ - exec( - http("CQ pserverzdeviceres " + env) - .put("/aai/v22/query?format=resource") - .headers(httpHeaders) - .body(ElFileBody("onap-CQ-pserver-zdevice.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @CQ vlanrangefromVlantag - */ - .repeat(3){ - exec( - http("CQ vlanrangefromVlantag " + env) - .put("/aai/v22/query?format=resource") - .headers(httpHeaders) - .body(ElFileBody("onap-CQ-vlanrange-fromVlantag.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @CQ pserverzdeviceres - */ - .repeat(3){ - exec( - http("CQ getClfiRoadmTailSummary " + env) - .put("/aai/v22/query?format=simple&nodesOnly=true") - .headers(httpHeaders) - .body(ElFileBody("onap-CQ-getClfiRoadmTailSummary.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @DSL Query1 - */ - .repeat(3){ - exec( - http("DSL Query1 PUT") - .put("/aai/v21/dsl?format=resource") - .headers(httpHeaders) - .body(ElFileBody("onap-DSL1.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @DSL Query2 - */ - .repeat(3){ - exec( - http("DSL Query2 PUT") - .put("/aai/v21/dsl?format=resource") - .headers(httpHeaders) - .body(ElFileBody("onap-DSL2.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @DSL Query3 - */ - .repeat(3){ - exec( - http("DSL Query3 PUT") - .put("/aai/v21/dsl?format=resource") - .headers(httpHeaders) - .body(ElFileBody("onap-DSL3.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @DSL Query4 - */ - .repeat(3){ - exec( - http("DSL Query4 PUT") - .put("/aai/v21/dsl?format=resource") - .headers(httpHeaders) - .body(ElFileBody("onap-DSL4.json")) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - /*** - * - * @param env - * @2min timeout - */ - .repeat(3){ - exec( - http("GetallCust " + env) - .get("/aai/v23/business/customers") - .headers(httpHeaders) - .check( - status.find.in(200) - ) - ) - .pause(1,1) - } - - setUp( - SingleAPITest("ePerf02").inject(atOnceUsers(1)).protocols(http.baseURL("Enter Host with Port")) - ) - .maxDuration(10 minutes) -}
\ No newline at end of file |