VOL-1774 Etcd Crash Handling
Change-Id: I1eeb726654c3972fd0a4fafae134607e5a810415
diff --git a/ro_core/main.go b/ro_core/main.go
index dc78302..b203bec 100644
--- a/ro_core/main.go
+++ b/ro_core/main.go
@@ -111,14 +111,16 @@
}
// Create the core service
- ro.core = c.NewCore(ro.config.InstanceID, ro.config, ro.kvClient)
+ ro.core = c.NewCore(ctx, ro.config.InstanceID, ro.config, ro.kvClient)
if p != nil {
p.UpdateStatus("kv-store", probe.ServiceStatusPrepared)
}
// start the core
- ro.core.Start(ctx)
+ if err := ro.core.Start(ctx); err != nil {
+ log.Fatalf("failed-to-start-rocore", log.Fields{"error": err})
+ }
}
func (ro *roCore) stop(ctx context.Context) {