summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
b50e1db)
- reduce request to Kafka/DMaaP
Issue-ID: OAM-327
Change-Id: I8b0c494aced642f4e129085dab10b772a7df73ed
Signed-off-by: Martin Skorupski <martin.skorupski@highstreet-technologies.com>
"paytoqs": "ignore",
"url": "https://ves-collector.oam.smo.o-ran-sc.org/eventListener/v7",
"tls": "7b2f4859e5963695",
"paytoqs": "ignore",
"url": "https://ves-collector.oam.smo.o-ran-sc.org/eventListener/v7",
"tls": "7b2f4859e5963695",
"proxy": "",
"insecureHTTPParser": false,
"authType": "basic",
"proxy": "",
"insecureHTTPParser": false,
"authType": "basic",
"type": "function",
"z": "c5746e29f53f72ce",
"name": "SET msg.url",
"type": "function",
"z": "c5746e29f53f72ce",
"name": "SET msg.url",
- "func": "const base = 'https://messages.smo.o-ran-sc.org';\nconst path = 'events';\nconst urlMapping = {\n pnfRegistration: \"unauthenticated.VES_PNFREG_OUTPUT\",\n o1NotifyPnfRegistration: \"unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT\",\n oRanScDuHelloWorldPmStreaming: \"unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT\",\n notifyHeartbeat: \"unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT\",\n notifyFileReady: \"unauthenticated.VES_FILE_READY_OUTPUT\",\n oRanOpenfrontManagementPlane: \"unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT\"\n};\nconst urlTopic = urlMapping[msg.topic] || msg.topic.replace(':', '-');\nmsg.url = [base, path, urlTopic, '1','1'].join('/');\nreturn msg;",
+ "func": "const base = 'https://messages.smo.o-ran-sc.org';\nconst path = 'events';\nconst urlMapping = {\n pnfRegistration: \"unauthenticated.VES_PNFREG_OUTPUT\",\n o1NotifyPnfRegistration: \"unauthenticated.VES_O1_NOTIFY_PNF_REGISTRATION_OUTPUT\",\n oRanScDuHelloWorldPmStreaming: \"unauthenticated.VES_O_RAN_SC_HELLO_WORLD_PM_STREAMING_OUTPUT\",\n notifyHeartbeat: \"unauthenticated.SEC_3GPP_HEARTBEAT_OUTPUT\",\n notifyFileReady: \"unauthenticated.VES_FILE_READY_OUTPUT\",\n oRanOpenfrontManagementPlane: \"unauthenticated.VES_O_RAN_SC_OPENFRONTHAUL_OUTPUT\"\n};\nconst longPolling = '?timeout=60000'\nconst urlTopic = urlMapping[msg.topic] || msg.topic.replace(':', '-');\nmsg.url = [base, path, urlTopic, '1', '1'].join('/') + longPolling;\nreturn msg;",
"outputs": 1,
"noerr": 0,
"initialize": "",
"outputs": 1,
"noerr": 0,
"initialize": "",
"crontab": "",
"once": false,
"onceDelay": 0.1,
"crontab": "",
"once": false,
"onceDelay": 0.1,