Code Review / dcaegen2 / services.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 2c6ad52) | patch
Add support to consume, process pm message from DB 58/112258/6
authordhebeha <dhebeha.mj71@wipro.com>
Tue, 8 Sep 2020 07:32:32 +0000 (13:02 +0530)
committerdhebeha <dhebeha.mj71@wipro.com>
Tue, 15 Sep 2020 16:41:14 +0000 (22:11 +0530)
commit8882e23eedce9e9236e1d979b2056b62dd974d91
treeff7bce29e94a814c340df73607b9d0da59a1329atree | snapshot
parent2c6ad52e8d0e29b8037776fff035f031558cc4b0commit | diff
Add support to consume, process pm message from DB
- Add support for analysing pm data
- Add support to trigger closed loop
- Add support for configDb Interface Implementation
- Add support for Intelligent slicing

Issue-ID: DCAEGEN2-2255
Signed-off-by: dhebeha <dhebeha.mj71@wipro.com>
Change-Id: I185dbb6da45ae6ee74f0a090e2d604914163588b
84 files changed:
components/slice-analysis-ms/.checkstyle diff | blob | history
components/slice-analysis-ms/pom.xml diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/Application.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/MainThread.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/beans/Configuration.java [deleted file] blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/configdb/ConfigDbInterfaceService.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/configdb/IConfigDbService.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/controller/ConfigFetchFromCbs.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/DmaapClient.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/IntelligentSlicingCallback.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/NewPmNotification.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/NotificationCallback.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PmNotificationCallback.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyDmaapClient.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/dmaap/PolicyNotificationCallback.java diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/CUModel.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/CellCUList.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/ConfigData.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/ConfigPolicy.java [moved from components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/beans/ConfigPolicy.java with 60% similarity] diff | blob | history
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/Configuration.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/MLOutputModel.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/MeasurementObject.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/SubCounter.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/configdb/CellsModel.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/configdb/NetworkFunctionModel.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/CommonEventHeader.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/Event.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/MeasDataCollection.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/MeasInfoId.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/MeasInfoList.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/MeasResult.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/MeasTypes.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/MeasValuesList.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/Perf3gppFields.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/pmnotification/PmNotification.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AAI.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/AdditionalProperties.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/OnsetMessage.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/models/policy/Payload.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/restclients/ConfigDbRestClient.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/restclients/RestClient.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/AverageCalculator.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/ConsumerThread.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/IPmEventProcessor.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/MLMessageProcessor.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmDataQueue.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmEventProcessor.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PmThread.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/PolicyService.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/service/SnssaiSamplesProcessor.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/main/java/org/onap/slice/analysis/ms/utils/DmaapUtils.java diff | blob | history
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/configdb/ConfigDbInterfaceServiceTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/dmaap/DmaapClientTest.java diff | blob | history
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/dmaap/NotificationConsumerTest.java diff | blob | history
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/dmaap/PolicyDmaapClientTest.java diff | blob | history
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/models/ConfigPolicyTest.java [moved from components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/beans/ConfigPolicyTest.java with 97% similarity] diff | blob | history
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/models/ConfigurationTest.java [moved from components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/beans/ConfigurationTest.java with 98% similarity] diff | blob | history
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/models/ModelsTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/models/pmnotification/PmModelsTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/models/policy/PolicyModelsTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/restclients/RestClientTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/service/AverageCalculatorTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/service/MLMessageProcessorTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/service/PmDataQueueTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/service/PmEventProcessorTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/service/PolicyServiceTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/java/org/onap/slice/analysis/ms/service/SnssaiSamplesProcessorTest.java [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/MLOutputModel.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/MLOutputModel1.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/appendData.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/average.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/config_all.json diff | blob | history
components/slice-analysis-ms/src/test/resources/event.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/eventProcessorOutput.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/getResponse.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/measurementObjectList.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/onsetMessage.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/ricConfiguration.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/ricToCellMapping.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/ricToPrbMap.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/ricToPrbOutput.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/ricToThroughputMappingOutput.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/serviceDetails.json [new file with mode: 0644] blob
components/slice-analysis-ms/src/test/resources/sliceMeasurementList.json [new file with mode: 0644] blob