From cd5c01501f0def47721525a6faef79bab696621e Mon Sep 17 00:00:00 2001 From: waynedunican Date: Tue, 13 Feb 2024 09:21:32 +0000 Subject: Update S3Ps to use Kafka Issue-ID: POLICY-4927 Change-Id: I3f57345543c86eb441dfb611d9e36b64e586433f Signed-off-by: waynedunican --- .../main/resources/apexPdpStabilityTestPlan.jmx | 740 ++++++++------------ .../main/resources/apexPdpPerformanceTestPlan.jmx | 778 +++++++++------------ 2 files changed, 600 insertions(+), 918 deletions(-) diff --git a/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx b/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx index 864e6f511..2561e4d5d 100644 --- a/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx +++ b/testsuites/apex-pdp-stability/src/main/resources/apexPdpStabilityTestPlan.jmx @@ -5,7 +5,7 @@ ================================================================================ Copyright (C) 2020-2022 Nordix Foundation.All rights reserved. Modifications Copyright (C) 2021 Bell Canada. All rights reserved. - Modifications Copyright (C) 2023 Nordix Foundation. + Modifications Copyright (C) 2024 Nordix Foundation. ================================================================================ Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. @@ -20,7 +20,7 @@ limitations under the License. ============LICENSE_END========================================================= --> - + false @@ -31,7 +31,7 @@ - + Content-Type @@ -45,11 +45,12 @@ - - - 23324 http + + + + @@ -85,9 +86,9 @@ ${__P(APEX_PORT,30001)} = - - DMAAP_PORT - ${__P(DMAAP_PORT,30904)} + + KAFKA_PORT + ${__P(KAFKA_PORT,29092)} = @@ -105,9 +106,9 @@ ${__P(LOG_PATH,/jmeter_results/apex_stability)} = - - SIM_HOST - ${__P(SIM_HOST,localhost)} + + KAFKA_HOST + ${__P(KAFKA_HOST,localhost)} = @@ -154,21 +155,26 @@ false - + + 1 + 1 + true continue - + 1 false - 1 - 1 - false - - - true - + + 6 + ${HOSTNAME} + ${API_PORT} + http + /policy/api/v1/policies + true + POST + true true @@ -208,7 +214,7 @@ "taskParameters": [ { "key": "logUrl", - "value": "http://${SIM_HOST}:${DMAAP_PORT}/events/APEX-CL-MGT" + "value": "http://${KAFKA_HOST}:${KAFKA_PORT}/events/apex-cl-mgt" } ] }, @@ -3222,10 +3228,23 @@ "eventInputParameters": { "ApexExample_DCAEConsumer": { "carrierTechnologyParameters": { - "carrierTechnology": "RESTCLIENT", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", "parameters": { - "url": "http://${SIM_HOST}:${DMAAP_PORT}/events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT/ApexExampleCG1/1?timeout=30000" + "bootstrapServers": "kafka:9092", + "groupId": "apex-grp2", + "enableAutoCommit": true, + "autoCommitTime": 1000, + "sessionTimeout": 30000, + "consumerPollTime": 100, + "consumerTopicList": [ + "unauthenticated.dcae_cl_output" + ], + "keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "kafkaProperties": [ + + ] } }, "eventProtocolParameters": { @@ -3303,8 +3322,22 @@ "eventOutputParameters": { "ApexExample_AAIProducer": { "carrierTechnologyParameters": { - "carrierTechnology": "RESTREQUESTOR", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restrequestor.RestRequestorCarrierTechnologyParameters" + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", + "parameters": { + "bootstrapServers": "kafka:9092", + "acks": "all", + "retries": 0, + "batchSize": 16384, + "lingerTime": 1, + "bufferMemory": 33554432, + "producerTopic": "apex-cl-mgt2", + "keySerializer": "org.apache.kafka.common.serialization.StringSerializer", + "valueSerializer": "org.apache.kafka.common.serialization.StringSerializer", + "kafkaProperties": [ + + ] + } }, "eventProtocolParameters": { "eventProtocol": "JSON" @@ -3319,7 +3352,7 @@ "carrierTechnology": "GRPC", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters", "parameters": { - "host": "${SIM_HOST}", + "host": "${KAFKA_HOST}", "port": ${CDS_PORT}, "username": "ccsdkapps", "password": "ccsdkapps", @@ -3339,7 +3372,7 @@ "carrierTechnology": "GRPC", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters", "parameters": { - "host": "${SIM_HOST}", + "host": "${KAFKA_HOST}", "port": ${CDS_PORT}, "username": "ccsdkapps", "password": "ccsdkapps", @@ -3365,21 +3398,6 @@ - ${HOSTNAME} - ${API_PORT} - http - /policy/api/v1/policies - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -3394,6 +3412,14 @@ + 6 + ${HOSTNAME} + ${API_PORT} + http + /policy/api/v1/policies + true + POST + true true @@ -6175,7 +6201,7 @@ "carrierTechnology": "RESTCLIENT", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", "parameters": { - "url": "http://${SIM_HOST}:${DMAAP_PORT}/events/unauthenticated.DCAE_CL_OUTPUT/cl/apex?timeout=30000" + "url": "http://${KAFKA_HOST}:${KAFKA_PORT}/events/unauthenticated.DCAE_CL_OUTPUT/cl/apex?timeout=30000" } }, "eventProtocolParameters": { @@ -6256,7 +6282,7 @@ "carrierTechnology": "GRPC", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters", "parameters": { - "host": "${SIM_HOST}", + "host": "${KAFKA_HOST}", "port": ${CDS_PORT}, "username": "ccsdkapps", "password": "ccsdkapps", @@ -6276,7 +6302,7 @@ "carrierTechnology": "RESTCLIENT", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", "parameters": { - "url": "http://${SIM_HOST}:${DMAAP_PORT}/events/APEX-CL-MGT" + "url": "http://${KAFKA_HOST}:${KAFKA_PORT}/events/APEX-CL-MGT" } }, "eventProtocolParameters": { @@ -6295,21 +6321,6 @@ - ${HOSTNAME} - ${API_PORT} - http - /policy/api/v1/policies - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -6324,6 +6335,14 @@ + 6 + ${HOSTNAME} + ${PAP_PORT} + http + /policy/pap/v1/pdps/deployments/batch + true + POST + true true @@ -6355,21 +6374,6 @@ - ${HOSTNAME} - ${PAP_PORT} - http - /policy/pap/v1/pdps/deployments/batch - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -6389,40 +6393,31 @@ + ${threads} + 1 + 259200 + true + true continue - + -1 false - ${threads} - 1 - true - 259200 - - true - false - false - - - + 6 ${HOSTNAME} ${APEX_PORT} http /policy/apex-pdp/v1/healthcheck - GET true - false + GET true - false - false - false - false - 6 - false - 0 + false + + + @@ -6456,25 +6451,18 @@ if (prev.getResponseCode() == '200') { - false - - - + 6 ${HOSTNAME} ${APEX_PORT} http /metrics - GET true - false + GET true - false - false - false - false - 6 - false - 0 + false + + + @@ -6512,26 +6500,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=500 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -6556,6 +6537,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - simplecl success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.DCAE_CL_OUTPUT + true + POST + true true @@ -6593,22 +6583,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_CL_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - simplecl success @@ -6629,26 +6603,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - simplecl success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=50&timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - simplecl success + false + + + @@ -6691,26 +6658,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=500 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -6735,6 +6695,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - simplecl failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.DCAE_CL_OUTPUT + true + POST + true true @@ -6772,22 +6741,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_CL_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - simplecl failure @@ -6808,26 +6761,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - simplecl failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=50&timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - simplecl failure + false + + + @@ -6891,26 +6837,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=500 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -6935,6 +6874,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - example success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT + true + POST + true true @@ -6974,22 +6922,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - example success @@ -7010,26 +6942,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - example success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=50&timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - example success + false + + + @@ -7072,26 +6997,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=500 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -7116,6 +7034,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - example failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT + true + POST + true true @@ -7155,22 +7082,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - example failure @@ -7191,26 +7102,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - example failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=50&timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - example failure + false + + + @@ -7251,20 +7155,25 @@ if (prev.getResponseCode() == '200') { + 1 + 1 + true continue - + 1 false - 1 - 1 - false - - - true + 6 + ${HOSTNAME} + ${PAP_PORT} + http + /policy/pap/v1/pdps/deployments/batch + true + POST + true true @@ -7296,21 +7205,6 @@ if (prev.getResponseCode() == '200') { - ${HOSTNAME} - ${PAP_PORT} - http - /policy/pap/v1/pdps/deployments/batch - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -7325,25 +7219,18 @@ if (prev.getResponseCode() == '200') { - false - - - + 6 ${HOSTNAME} ${API_PORT} http /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies/onap.policies.apex.Simplecontrolloop/versions/1.0.0 - DELETE true - false + DELETE true - false - false - false - false - 6 - false - 0 + false + + + @@ -7358,25 +7245,18 @@ if (prev.getResponseCode() == '200') { - false - - - + 6 ${HOSTNAME} ${API_PORT} http /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies/onap.policies.apex.Example/versions/1.0.0 - DELETE true - false + DELETE true - false - false - false - false - 6 - false - 0 + false + + + @@ -7392,40 +7272,31 @@ if (prev.getResponseCode() == '200') { + ${threads} + 1 + 259200 + true + true continue - + -1 false - ${threads} - 1 - true - 259200 - - true - false - false - - - + 6 ${HOSTNAME} ${APEX_PORT} https /policy/apex-pdp/v1/healthcheck - GET true - false + GET true - false - false - false - false - 6 - false - 0 + false + + + @@ -7456,6 +7327,15 @@ if (prev.getResponseCode() == '200') { + Send input event to apex-pdp + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.DCAE_CL_OUTPUT + true + POST + true true @@ -7493,22 +7373,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_CL_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send input event to apex-pdp @@ -7529,26 +7393,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + @@ -7586,26 +7443,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=1&timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + @@ -7642,26 +7492,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=1&timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + @@ -7711,26 +7554,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http /events/APEX-CL-MGT/cg${__threadNum}/c1?timeout=30000 - GET true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + diff --git a/testsuites/performance/performance-benchmark-test/src/main/resources/apexPdpPerformanceTestPlan.jmx b/testsuites/performance/performance-benchmark-test/src/main/resources/apexPdpPerformanceTestPlan.jmx index 61e82e1c2..bb6870d17 100644 --- a/testsuites/performance/performance-benchmark-test/src/main/resources/apexPdpPerformanceTestPlan.jmx +++ b/testsuites/performance/performance-benchmark-test/src/main/resources/apexPdpPerformanceTestPlan.jmx @@ -5,7 +5,7 @@ ================================================================================ Copyright (C) 2020-2022 Nordix Foundation.All rights reserved. Modifications Copyright (C) 2021 Bell Canada. All rights reserved. - Modifications Copyright (C) 2023 Nordix Foundation. + Modifications Copyright (C) 2024 Nordix Foundation. ================================================================================ Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. @@ -20,7 +20,7 @@ limitations under the License. ============LICENSE_END========================================================= --> - + @@ -33,7 +33,7 @@ - + Content-Type @@ -47,11 +47,12 @@ - - - 23324 http + + + + @@ -87,9 +88,9 @@ ${__P(APEX_PORT,30001)} = - - DMAAP_PORT - ${__P(DMAAP_PORT,30904)} + + KAFKA_PORT + ${__P(KAFKA_PORT,29092)} = @@ -107,9 +108,9 @@ ${__P(LOG_PATH,/jmeter_results/apex_perf)} = - - SIM_HOST - ${__P(SIM_HOST,localhost)} + + KAFKA_HOST + ${__P(KAFKA_HOST,localhost)} = @@ -157,20 +158,25 @@ + 1 + 1 + true continue - + 1 false - 1 - 1 - false - - - true - + + 6 + ${HOSTNAME} + ${API_PORT} + http + /policy/api/v1/policies + true + POST + true true @@ -210,7 +216,7 @@ "taskParameters": [ { "key": "logUrl", - "value": "http://${SIM_HOST}:${DMAAP_PORT}/events/APEX-CL-MGT" + "value": "http://${KAFKA_HOST}:${KAFKA_PORT}/events/apex-cl-mgt" } ] }, @@ -3224,10 +3230,23 @@ "eventInputParameters": { "ApexExample_DCAEConsumer": { "carrierTechnologyParameters": { - "carrierTechnology": "RESTCLIENT", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", "parameters": { - "url": "http://${SIM_HOST}:${DMAAP_PORT}/events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT/ApexExampleCG1/1?timeout=30000" + "bootstrapServers": "kafka:9092", + "groupId": "apex-grp2", + "enableAutoCommit": true, + "autoCommitTime": 1000, + "sessionTimeout": 30000, + "consumerPollTime": 100, + "consumerTopicList": [ + "unauthenticated.dcae_cl_output" + ], + "keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "kafkaProperties": [ + + ] } }, "eventProtocolParameters": { @@ -3321,7 +3340,7 @@ "carrierTechnology": "GRPC", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters", "parameters": { - "host": "${SIM_HOST}", + "host": "${KAFKA_HOST}", "port": ${CDS_PORT}, "username": "ccsdkapps", "password": "ccsdkapps", @@ -3341,7 +3360,7 @@ "carrierTechnology": "GRPC", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters", "parameters": { - "host": "${SIM_HOST}", + "host": "${KAFKA_HOST}", "port": ${CDS_PORT}, "username": "ccsdkapps", "password": "ccsdkapps", @@ -3367,21 +3386,6 @@ - ${HOSTNAME} - ${API_PORT} - http - /policy/api/v1/policies - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -3395,7 +3399,15 @@ - + + 6 + ${HOSTNAME} + ${API_PORT} + http + /policy/api/v1/policies + true + POST + true true @@ -6174,10 +6186,23 @@ "eventInputParameters": { "SimpleCL_DCAEConsumer": { "carrierTechnologyParameters": { - "carrierTechnology": "RESTCLIENT", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", "parameters": { - "url": "http://${SIM_HOST}:${DMAAP_PORT}/events/unauthenticated.DCAE_CL_OUTPUT/cl/apex?timeout=30000" + "bootstrapServers": "kafka:9092", + "groupId": "apex-grp2", + "enableAutoCommit": true, + "autoCommitTime": 1000, + "sessionTimeout": 30000, + "consumerPollTime": 100, + "consumerTopicList": [ + "unauthenticated.dcae_cl_output" + ], + "keyDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "valueDeserializer": "org.apache.kafka.common.serialization.StringDeserializer", + "kafkaProperties": [ + + ] } }, "eventProtocolParameters": { @@ -6258,7 +6283,7 @@ "carrierTechnology": "GRPC", "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.grpc.GrpcCarrierTechnologyParameters", "parameters": { - "host": "${SIM_HOST}", + "host": "${KAFKA_HOST}", "port": ${CDS_PORT}, "username": "ccsdkapps", "password": "ccsdkapps", @@ -6275,10 +6300,21 @@ }, "SimpleCL_LogEventProducer": { "carrierTechnologyParameters": { - "carrierTechnology": "RESTCLIENT", - "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.restclient.RestClientCarrierTechnologyParameters", + "carrierTechnology": "KAFKA", + "parameterClassName": "org.onap.policy.apex.plugins.event.carrier.kafka.KafkaCarrierTechnologyParameters", "parameters": { - "url": "http://${SIM_HOST}:${DMAAP_PORT}/events/APEX-CL-MGT" + "bootstrapServers": "kafka:9092", + "acks": "all", + "retries": 0, + "batchSize": 16384, + "lingerTime": 1, + "bufferMemory": 33554432, + "producerTopic": "apex-cl-mgt2", + "keySerializer": "org.apache.kafka.common.serialization.StringSerializer", + "valueSerializer": "org.apache.kafka.common.serialization.StringSerializer", + "kafkaProperties": [ + + ] } }, "eventProtocolParameters": { @@ -6297,21 +6333,6 @@ - ${HOSTNAME} - ${API_PORT} - http - /policy/api/v1/policies - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -6326,6 +6347,14 @@ + 6 + ${HOSTNAME} + ${PAP_PORT} + http + /policy/pap/v1/pdps/deployments/batch + true + POST + true true @@ -6357,21 +6386,6 @@ - ${HOSTNAME} - ${PAP_PORT} - http - /policy/pap/v1/pdps/deployments/batch - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -6391,40 +6405,31 @@ + ${threads} + 1 + 7200 + true + true continue - + -1 false - ${threads} - 1 - true - 7200 - - true - false - false - - - + 6 ${HOSTNAME} ${APEX_PORT} http /policy/apex-pdp/v1/healthcheck - GET true - false + GET true - false - false - false - false - 6 - false - 0 + false + + + @@ -6458,25 +6463,18 @@ if (prev.getResponseCode() == '200') { - false - - - + 6 ${HOSTNAME} ${APEX_PORT} http /metrics - GET true - false + GET true - false - false - false - false - 6 - false - 0 + false + + + @@ -6514,26 +6512,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=300&timeout=500 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=300&timeout=500 true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -6558,6 +6549,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - simplecl success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.dcae_cl_output + true + POST + true true @@ -6595,22 +6595,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_CL_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - simplecl success @@ -6631,26 +6615,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - simplecl success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=100&timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - simplecl success + false + + + @@ -6693,26 +6670,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=300&timeout=500 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=300&timeout=500 true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -6737,6 +6707,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - simplecl failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.dcae_cl_output + true + POST + true true @@ -6774,22 +6753,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_CL_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - simplecl failure @@ -6810,26 +6773,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - simplecl failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=100&timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - simplecl failure + false + + + @@ -6871,26 +6827,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=300&timeout=500 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=300&timeout=500 true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -6915,6 +6864,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - example success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.dcae_policy_example_output + true + POST + true true @@ -6954,22 +6912,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - example success @@ -6990,26 +6932,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - example success + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=100&timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - example success + false + + + @@ -7052,26 +6987,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Clean up DMaaP notification topic + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=300&timeout=500 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=300&timeout=500 true - false + GET true - false - false - false - false - 6 - false - 0 - Clean up DMaaP notification topic + false + + + @@ -7096,6 +7024,15 @@ if (prev.getResponseCode() == '200') { + Send Trigger Event - example failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.dcae_policy_example_output + true + POST + true true @@ -7135,22 +7072,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_POLICY_EXAMPLE_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send Trigger Event - example failure @@ -7171,26 +7092,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Read notification events - example failure + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=100&timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=100&timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Read notification events - example failure + false + + + @@ -7231,20 +7145,25 @@ if (prev.getResponseCode() == '200') { + 1 + 1 + true continue - + 1 false - 1 - 1 - false - - - true + 6 + ${HOSTNAME} + ${PAP_PORT} + https + /policy/pap/v1/pdps/deployments/batch + true + POST + true true @@ -7276,21 +7195,6 @@ if (prev.getResponseCode() == '200') { - ${HOSTNAME} - ${PAP_PORT} - https - /policy/pap/v1/pdps/deployments/batch - POST - true - false - true - false - false - false - false - 6 - false - 0 @@ -7305,25 +7209,18 @@ if (prev.getResponseCode() == '200') { - false - - - + 6 ${HOSTNAME} ${API_PORT} https /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies/onap.policies.apex.Simplecontrolloop/versions/1.0.0 - DELETE true - false + DELETE true - false - false - false - false - 6 - false - 0 + false + + + @@ -7338,25 +7235,18 @@ if (prev.getResponseCode() == '200') { - false - - - + 6 ${HOSTNAME} ${API_PORT} https /policy/api/v1/policytypes/onap.policies.native.Apex/versions/1.0.0/policies/onap.policies.apex.Example/versions/1.0.0 - DELETE true - false + DELETE true - false - false - false - false - 6 - false - 0 + false + + + @@ -7372,40 +7262,31 @@ if (prev.getResponseCode() == '200') { + ${threads} + 1 + 259200 + true + true continue - + -1 false - ${threads} - 1 - true - 259200 - - true - false - false - - - + 6 ${HOSTNAME} ${APEX_PORT} https /policy/apex-pdp/v1/healthcheck - GET true - false + GET true - false - false - false - false - 6 - false - 0 + false + + + @@ -7436,6 +7317,15 @@ if (prev.getResponseCode() == '200') { + Send input event to apex-pdp + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} + http + /events/unauthenticated.dcae_cl_output + true + POST + true true @@ -7473,22 +7363,6 @@ if (prev.getResponseCode() == '200') { - ${SIM_HOST} - ${DMAAP_PORT} - http - /events/unauthenticated.DCAE_CL_OUTPUT - POST - true - false - true - false - false - false - false - 6 - false - 0 - Send input event to apex-pdp @@ -7509,26 +7383,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + @@ -7566,26 +7433,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=1&timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=1&timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + @@ -7622,26 +7482,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?limit=1&timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?limit=1&timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + @@ -7691,26 +7544,19 @@ if (prev.getResponseCode() == '200') { - false - - - - ${SIM_HOST} - ${DMAAP_PORT} + Check output event + 6 + ${KAFKA_HOST} + ${KAFKA_PORT} http - /events/APEX-CL-MGT/cg${__threadNum}/c1?timeout=30000 - GET + /events/apex-cl-mgt/cg${__threadNum}/c1?timeout=30000 true - false + GET true - false - false - false - false - 6 - false - 0 - Check output event + false + + + -- cgit 1.2.3-korg