VOL-1465 : Integrate rw sync fixes into ro core
- Added new config-map for affinity router
- Removed some really verbose model logs
- Fail core when kv client cannot be established
Change-Id: I7f10c7ce3121abaf88fa622aecb3affd40813d67
diff --git a/ro_core/main.go b/ro_core/main.go
index c86cd45..599fe9f 100644
--- a/ro_core/main.go
+++ b/ro_core/main.go
@@ -96,7 +96,11 @@
// Setup KV Client
log.Debugw("create-kv-client", log.Fields{"kvstore": ro.config.KVStoreType})
- ro.setKVClient()
+
+ if err := ro.setKVClient(); err != nil {
+ log.Fatalw("failed-to-connect-kv-client", log.Fields{"error": err})
+ return
+ }
// Create the core service
ro.core = c.NewCore(ro.config.InstanceID, ro.config, ro.kvClient)