commit b4c25916f6108280baf8131890ec00d482e58954
author Himani Chawla <hichawla@ciena.com> Thu Nov 12 17:16:38 2020 +0530
committer Himani Chawla <hichawla@ciena.com> Mon Feb 08 11:29:03 2021 +0530
tree 109e9b8376ebaff2de63bbf81348960f1a1e8372
parent 40af27097265b5a5dacd7eb831254b713b567fc0

VOL-3501 Code changes to support rpc event

Change-Id: I2536c0c03faa5fb026349c906ebef46323398e9a

rw_core/config/config.go

diff --git a/rw_core/config/config.go b/rw_core/config/config.go
index 03abc67..6a29e16 100644
--- a/rw_core/config/config.go
+++ b/rw_core/config/config.go
@@ -37,6 +37,7 @@
 	defaultBanner                    = false
 	defaultDisplayVersionOnly        = false
 	defaultCoreTopic                 = "rwcore"
+	defaultEventTopic                = "voltha.events"
 	defaultRWCoreEndpoint            = "rwcore"
 	defaultRWCoreKey                 = "pki/voltha.key"
 	defaultRWCoreCert                = "pki/voltha.crt"
@@ -67,6 +68,7 @@
 	KVStoreAddress            string
 	KVTxnKeyDelTime           int
 	CoreTopic                 string
+	EventTopic                string
 	LogLevel                  string
 	Banner                    bool
 	DisplayVersionOnly        bool
@@ -99,6 +101,7 @@
 		KVStoreAddress:            defaultKVStoreAddress,
 		KVTxnKeyDelTime:           defaultKVTxnKeyDelTime,
 		CoreTopic:                 defaultCoreTopic,
+		EventTopic:                defaultEventTopic,
 		LogLevel:                  defaultLogLevel,
 		Banner:                    defaultBanner,
 		DisplayVersionOnly:        defaultDisplayVersionOnly,
@@ -139,6 +142,9 @@
 	help = fmt.Sprintf("RW Core topic")
 	flag.StringVar(&(cf.CoreTopic), "rw_core_topic", defaultCoreTopic, help)
 
+	help = fmt.Sprintf("RW Core Event topic")
+	flag.StringVar(&(cf.EventTopic), "event_topic", defaultEventTopic, help)
+
 	flag.Bool("in_competing_mode", false, "deprecated")
 
 	help = fmt.Sprintf("KV store type")