Kafka dispatcher module backbone 26/8626/17
authorhalil.cakal <halil.cakal@est.tech>
Tue, 21 Jun 2022 11:05:14 +0000 (12:05 +0100)
committerJohn Keeney <john.keeney@est.tech>
Fri, 29 Jul 2022 09:25:23 +0000 (09:25 +0000)
commit1ef05f94c2b4cc34f4b4b7e891b41548ad9bf446
tree66442d29feda678d4c25bf02c14e66571792c7cc
parent30f41fcbaa50eef322aa47efe8346b432b96b578
Kafka dispatcher module backbone

Patch set 2: Creates a Python-adapter dispatching HTTP/HTTPS requests to a Kafka broker using kafka-python library.
Patch set 3: Develops a consumer capable of deserializing JSON messages. Clean up redundant functions and parameters.
Patch set 4: Develops a feature that publishes and consumes (to/from) the Kafka cluster in two-way synch.
Patch set 5: Develops unit tests cases.
Patch set 6: Develops a feature capable of handling requestid sent in headers for error testing.
Patch set 7: Develops asynch error test cases.
Patch set 8: Develops configurable look-up talbe that maps policy-type to kafka-topic. Supports multi topic including unit tests cases with error based.
Patch set 9: Develops publish-consume kafka message for get-policy-status operation. Enriches unit test cases.
Patch set 10: Validate open API yaml and fixes review.
Patch set 11: Develops an actual kafka response processing including unit test-cases with error based.
Patch set 12: Develops configurable response topic to be consumed from, apply changes to policytypetotopicmapping API. Adds unit test case.
Patch set 13: Plugs in kafka dispatcher module to A1 Sim to realize e2e sequence.
Patch set 14: Develops error testing script in which timeout value is being parametric.
Patch set 15: Calculates poll cycle treshold and develops more validation on time out param.

Issue-ID: NONRTRIC-757
Change-Id: I9bd257691d8a50e81492c55a5ec17a4409d9da6c
Signed-off-by: halil.cakal <halil.cakal@est.tech>
26 files changed:
near-rt-ric-simulator/src/STD_2.0.0/a1.py [changed mode: 0644->0755]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/Dockerfile [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/api/KAFKA_DISPATCHER_api.yaml [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/certificate/cert.crt [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/certificate/generate_cert_and_key.sh [new file with mode: 0755]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/certificate/key.crt [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/certificate/pass [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/nginx.conf [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/resources/policytype_to_topicmap.json [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/dispatcher.py [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/main.py [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/maincommon.py [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/payload_logging.py [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/start.sh [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER/src/var_declaration.py [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/basic_test.sh [new file with mode: 0755]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/basic_test_with_cust_header.sh [new file with mode: 0755]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/build_and_start.sh [new file with mode: 0755]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/jsonfiles/ANR_to_topic_map.json [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/jsonfiles/alpha_policy.json [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/jsonfiles/beta_policy.json [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/jsonfiles/forced_response.json [new file with mode: 0644]
near-rt-ric-simulator/test/KAFKA_DISPATCHER_TEST/jsonfiles/timeout_response.json [new file with mode: 0644]
near-rt-ric-simulator/test/STD_2.0.0/build_and_start_with_kafka.sh [new file with mode: 0755]
near-rt-ric-simulator/test/common/publish_response_event_to_kafka_bus.py [new file with mode: 0644]
near-rt-ric-simulator/test/common/test_common.sh