DMaaP adapter, updated job definition syntax 42/10242/2
authorPatrikBuhr <patrik.buhr@est.tech>
Thu, 5 Jan 2023 13:06:38 +0000 (14:06 +0100)
committerPatrikBuhr <patrik.buhr@est.tech>
Tue, 10 Jan 2023 08:49:30 +0000 (09:49 +0100)
commitc32ab314a9a9b46df45e2c3d48b59b0b28a807a3
tree125ca7905a0e70e4d3e81733437e929d5be9c3c7
parent76df3282b858a64b615746ae8881776d829ff103
DMaaP adapter, updated job definition syntax

The filter syntax is updated so that measTypes are structured below measuredObjClass
The job definition is updated so that the output contains both topic and the kafka boostrap servers.
Graceful shutdown of Dmaap Adapter

Example of PM definition after the change:

{
   "filter":{
      "sourceNames":[
         "NodeA", "NodeB"
      ],
      "measObjInstIds":[

      ],
      "measTypeSpecs":[
         {
            "measuredObjClass":"NRCellCU",
            "measTypes":[
               "pmCounterNumber0"
            ]
         }
      ],
      "measuredEntityDns":[

      ]
   },
   "deliveryInfo":{
      "topic":"ouputTopic",
      "bootStrapServers":"localhost:9092"
   }
}

Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-831
Change-Id: Ifbdeb676fce22eaff3c6e35eb50c76a661ea27fa
18 files changed:
api/api.json
api/api.yaml
config/application.yaml
docs/overview.rst
src/main/java/org/oran/dmaapadapter/Application.java
src/main/java/org/oran/dmaapadapter/clients/AsyncRestClient.java
src/main/java/org/oran/dmaapadapter/configuration/ApplicationConfig.java
src/main/java/org/oran/dmaapadapter/filter/PmReportFilter.java
src/main/java/org/oran/dmaapadapter/repository/Job.java
src/main/java/org/oran/dmaapadapter/repository/Jobs.java
src/main/java/org/oran/dmaapadapter/tasks/KafkaJobDataDistributor.java
src/main/java/org/oran/dmaapadapter/tasks/TopicListeners.java
src/main/resources/typeSchema.json
src/main/resources/typeSchemaPmData.json
src/test/java/org/oran/dmaapadapter/ApplicationTest.java
src/test/java/org/oran/dmaapadapter/IntegrationWithKafka.java
src/test/java/org/oran/dmaapadapter/filter/PmReportFilterTest.java
src/test/resources/pm_report.json