commit ffc89df486ba6e8664975ebef8e3899d9c227f78
author Devmalya Paul <Devmalya.Paul@radisys.com> Wed Jul 31 17:43:13 2019 -0400
committer Matt Jeanneret <mj3580@att.com> Thu Sep 05 10:17:03 2019 -0400
tree 449c0637ecd5e7d11483573af0f28507e53291d8
parent 8fb96783bb2b54a4161a8e10b7ece747dd729eea

Migration to new event defination for OpenONU adapter

     This change is for the migration of alarms and KPIs for earlier
     separate defination of AlarmEvent and KPIEvent to a generic format
     called Event where it could be an alarm or a KPI event

     An event manager adapter_events handles the event submission.

Change-Id: If088a1876fbbae2975ef77c4364dd96bbe361c8d

python/adapters/brcm_openomci_onu/main.py

diff --git a/python/adapters/brcm_openomci_onu/main.py b/python/adapters/brcm_openomci_onu/main.py
index d0eadcb..54f171c 100755
--- a/python/adapters/brcm_openomci_onu/main.py
+++ b/python/adapters/brcm_openomci_onu/main.py
@@ -59,6 +59,7 @@
     accept_atomic_flow=os.environ.get('ACCEPT_ATOMIC_FLOW', True),
     etcd=os.environ.get('ETCD', 'localhost:2379'),
     core_topic=os.environ.get('CORE_TOPIC', 'rwcore'),
+    event_topic=os.environ.get('EVENT_TOPIC', 'voltha.events'),
     interface=os.environ.get('INTERFACE', get_my_primary_interface()),
     instance_id=os.environ.get('INSTANCE_ID', os.environ.get('HOSTNAME', '1')),
     kafka_adapter=os.environ.get('KAFKA_ADAPTER', '192.168.0.20:9092'),
@@ -223,6 +224,13 @@
                         default=defs['core_topic'],
                         help=_help)
 
+    _help = 'topic of events on the kafka bus'
+    parser.add_argument('-et', '--event_topic',
+                        dest='event_topic',
+                        action='store',
+                        default=defs['event_topic'],
+                        help=_help)
+
     args = parser.parse_args()
 
     # post-processing
@@ -280,6 +288,7 @@
         self.instance_id = self.args.instance_id + '_' + str(current_time)
 
         self.core_topic = args.core_topic
+        self.event_topic = args.event_topic
         self.listening_topic = args.name
         self.startup_components()
 
@@ -349,6 +358,7 @@
             self.core_proxy = CoreProxy(
                 kafka_proxy=None,
                 default_core_topic=self.core_topic,
+                default_event_topic=self.event_topic,
                 my_listening_topic=self.listening_topic)
 
             self.adapter_proxy = AdapterProxy(