Skip to content
Snippets Groups Projects
Commit ffd0c150 authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Common - Kafka tools: 

- Added NBI_SOCKETIO_WORKERS channel
parent 312f7036
No related branches found
No related tags found
4 merge requests!346Draft: support for restconf protocol,!345Draft: support ipinfusion devices via netconf,!328Resolve "(CTTC) Update recommendations to use SocketIO on NBI and E2E Orch components",!286Resolve "(CTTC) Implement integration test between E2E-IP-Optical SDN Controllers"
Hide whitespace changes
Inline Side-by-side
src/common/tools/kafka/Variables.py
+ 11
− 10
View file @ ffd0c150
...@@ -47,16 +47,17 @@ class KafkaConfig(Enum): ...@@ -47,16 +47,17 @@ class KafkaConfig(Enum):
class KafkaTopic(Enum): class KafkaTopic(Enum):
# TODO: Later to be populated from ENV variable. # TODO: Later to be populated from ENV variable.
TELEMETRY_REQUEST = 'topic_telemetry_request' TELEMETRY_REQUEST = 'topic_telemetry_request'
TELEMETRY_RESPONSE = 'topic_telemetry_response' TELEMETRY_RESPONSE = 'topic_telemetry_response'
RAW = 'topic_raw' RAW = 'topic_raw'
LABELED = 'topic_labeled' LABELED = 'topic_labeled'
VALUE = 'topic_value' VALUE = 'topic_value'
ALARMS = 'topic_alarms' ALARMS = 'topic_alarms'
ANALYTICS_REQUEST = 'topic_analytics_request' ANALYTICS_REQUEST = 'topic_analytics_request'
ANALYTICS_RESPONSE = 'topic_analytics_response' ANALYTICS_RESPONSE = 'topic_analytics_response'
VNTMANAGER_REQUEST = 'topic_vntmanager_request' VNTMANAGER_REQUEST = 'topic_vntmanager_request'
VNTMANAGER_RESPONSE = 'topic_vntmanager_response' VNTMANAGER_RESPONSE = 'topic_vntmanager_response'
NBI_SOCKETIO_WORKERS = 'tfs-nbi-socketio'
@staticmethod @staticmethod
def create_all_topics() -> bool: def create_all_topics() -> bool:
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment