integration-test/src/test/groovy/org/onap/cps/integration/performance/cps/WritePerfTest.groovy

   1 /*
   2  *  ============LICENSE_START=======================================================
   3  *  Copyright (C) 2023 Nordix Foundation
   4  *  ================================================================================
   5  *  Licensed under the Apache License, Version 2.0 (the 'License');
   6  *  you may not use this file except in compliance with the License.
   7  *  You may obtain a copy of the License at
   8  *
   9  *        http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *  Unless required by applicable law or agreed to in writing, software
  12  *  distributed under the License is distributed on an 'AS IS' BASIS,
  13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *  See the License for the specific language governing permissions and
  15  *  limitations under the License.
  16  *
  17  *  SPDX-License-Identifier: Apache-2.0
  18  *  ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.cps.integration.performance.cps
  22
  23 import java.time.OffsetDateTime
  24 import org.onap.cps.integration.performance.base.CpsPerfTestBase
  25
  26 class WritePerfTest extends CpsPerfTestBase {
  27
  28     def 'Writing openroadm data has linear time.'() {
  29         given: 'an empty anchor exists for openroadm'
  30             cpsAnchorService.createAnchor(CPS_PERFORMANCE_TEST_DATASPACE, LARGE_SCHEMA_SET, 'writeAnchor')
  31         and: 'a list of device nodes to add'
  32             def jsonData = generateOpenRoadData(totalNodes)
  33         when: 'device nodes are added'
  34             resourceMeter.start()
  35             cpsDataService.saveData(CPS_PERFORMANCE_TEST_DATASPACE, 'writeAnchor', jsonData, OffsetDateTime.now())
  36             resourceMeter.stop()
  37             def durationInSeconds = resourceMeter.getTotalTimeInSeconds()
  38         then: 'the operation takes less than #expectedDuration and memory used is within limit'
  39             recordAndAssertResourceUsage("Writing ${totalNodes} devices", expectedDuration, durationInSeconds, memoryLimit, resourceMeter.getTotalMemoryUsageInMB())
  40         cleanup:
  41             cpsDataService.deleteDataNodes(CPS_PERFORMANCE_TEST_DATASPACE, 'writeAnchor', OffsetDateTime.now())
  42             cpsAnchorService.deleteAnchor(CPS_PERFORMANCE_TEST_DATASPACE, 'writeAnchor')
  43         where:
  44             totalNodes || expectedDuration | memoryLimit
  45             50         || 4                | 100
  46             100        || 7                | 200
  47             200        || 14               | 400
  48             400        || 28               | 500
  49     }
  50
  51     def 'Writing bookstore data has exponential time.'() {
  52         given: 'an anchor containing a bookstore with a single category'
  53             cpsAnchorService.createAnchor(CPS_PERFORMANCE_TEST_DATASPACE, BOOKSTORE_SCHEMA_SET, 'writeAnchor')
  54             def parentNodeData = '{"bookstore": { "categories": [{ "code": 1, "name": "Test", "books" : [] }] }}'
  55             cpsDataService.saveData(CPS_PERFORMANCE_TEST_DATASPACE, 'writeAnchor', parentNodeData, OffsetDateTime.now())
  56         and: 'a list of books to add'
  57             def booksData = '{"books":[' + (1..totalBooks).collect {'{ "title": "' + it + '" }' }.join(',') + ']}'
  58         when: 'books are added'
  59             resourceMeter.start()
  60             cpsDataService.saveData(CPS_PERFORMANCE_TEST_DATASPACE, 'writeAnchor', '/bookstore/categories[@code=1]', booksData, OffsetDateTime.now())
  61             resourceMeter.stop()
  62             def durationInSeconds = resourceMeter.getTotalTimeInSeconds()
  63         then: 'the operation takes less than #expectedDuration and memory used is within limit'
  64             recordAndAssertResourceUsage("Writing ${totalBooks} books", expectedDuration, durationInSeconds, memoryLimit, resourceMeter.getTotalMemoryUsageInMB())
  65         cleanup:
  66             cpsDataService.deleteDataNodes(CPS_PERFORMANCE_TEST_DATASPACE, 'writeAnchor', OffsetDateTime.now())
  67             cpsAnchorService.deleteAnchor(CPS_PERFORMANCE_TEST_DATASPACE, 'writeAnchor')
  68         where:
  69             totalBooks || expectedDuration | memoryLimit
  70             800        || 1                | 50
  71             1600       || 2                | 100
  72             3200       || 6                | 150
  73             6400       || 18               | 200
  74     }
  75
  76 }