VOL-1774 Etcd Crash Handling
Change-Id: I1eeb726654c3972fd0a4fafae134607e5a810415
diff --git a/rw_core/main.go b/rw_core/main.go
index c066275..76d0952 100644
--- a/rw_core/main.go
+++ b/rw_core/main.go
@@ -140,10 +140,13 @@
}
// Create the core service
- rw.core = c.NewCore(instanceID, rw.config, rw.kvClient, rw.kafkaClient)
+ rw.core = c.NewCore(ctx, instanceID, rw.config, rw.kvClient, rw.kafkaClient)
// start the core
- rw.core.Start(ctx)
+ err = rw.core.Start(ctx)
+ if err != nil {
+ log.Fatalf("failed-to-start-rwcore", log.Fields{"error": err})
+ }
}
func (rw *rwCore) stop(ctx context.Context) {