Code Review / integration / simulators / nf-simulator / netconf-server.git / commit
? search:
summary | shortlog | log | commit | commitdiff | review | tree
(parent: 06daadc) | patch
Add Kafka support 11/120011/6
authorBogumil Zebek <bogumil.zebek@nokia.com>
Tue, 30 Mar 2021 13:01:37 +0000 (15:01 +0200)
committerZebek Bogumil <bogumil.zebek@nokia.com>
Fri, 2 Apr 2021 05:39:48 +0000 (07:39 +0200)
commitc0d47aca4a13b239e51772fa366fa780ec7812da
tree7561c4f7654de3dba3d0e1c1de3f8c68fe75fff4tree | snapshot
parent06daadc4403397935c647dca2bbb92459864d12acommit | diff
Add Kafka support

- send changes on Kafka topic
- add endpoint for fetching changes from Kafka

Signed-off-by: Bogumil Zebek <bogumil.zebek@nokia.com>
Issue-ID: INT-1869
Signed-off-by: Zebek Bogumil <bogumil.zebek@nokia.com>
Change-Id: I349fdc4295659fc69407b5b1138281e2673f7938
18 files changed:
Dockerfile diff | blob | history
pom.xml diff | blob | history
src/python/netconf_change_listener_application.py diff | blob | history
src/python/netconf_rest_application.py diff | blob | history
src/python/netconf_server/kafka_consumer_factory.py [new file with mode: 0644] blob
src/python/netconf_server/netconf_app_configuration.py diff | blob | history
src/python/netconf_server/netconf_change_listener.py diff | blob | history
src/python/netconf_server/netconf_change_listener_factory.py diff | blob | history
src/python/netconf_server/netconf_kafka_client.py diff | blob | history
src/python/netconf_server/netconf_kafka_message_factory.py [new file with mode: 0644] blob
src/python/netconf_server/netconf_rest_server.py diff | blob | history
src/python/netconf_server/sysrepo_interface/config_change_subscriber.py diff | blob | history
src/python/netconf_server/sysrepo_interface/sysrepo_message_model.py [new file with mode: 0644] blob
src/python/requirements.txt diff | blob | history
src/python/test-requirements.txt diff | blob | history
src/python/tests/unit/test_netconf_change_listener.py [new file with mode: 0644] blob
src/python/tests/unit/test_netconf_change_listener_factory.py [moved from src/python/tests/unit/test_netconf_chang_listener.py with 61% similarity] diff | blob | history
src/python/tests/unit/test_netconf_kafka_message_factory.py [new file with mode: 0644] blob
"integration_simulators_netconf_server"