Programmatic way of knowing that Conduit has been initialized (#1224)

pkg/conduit/runtime.go

@@ -77,15 +77,17 @@ type Runtime struct {
 	DB               database.DB
 	Orchestrator     *orchestrator.Orchestrator
 	ProvisionService *provisioning.Service
+	// Ready will be closed when Runtime has successfully started
+	Ready chan struct{}
 
 	pipelineService  *pipeline.Service
 	connectorService *connector.Service
 	processorService *processor.Service
-	pluginService    *plugin.Service
 
-	connectorPersister *connector.Persister
+	pluginService *plugin.Service
 
-	logger log.CtxLogger
+	connectorPersister *connector.Persister
+	logger             log.CtxLogger
 }
 
 // NewRuntime sets up a Runtime instance and primes it for start.
@@ -141,6 +143,7 @@ func NewRuntime(cfg Config) (*Runtime, error) {
 		DB:               db,
 		Orchestrator:     orc,
 		ProvisionService: provisionService,
+		Ready:            make(chan struct{}),
 
 		pipelineService:  plService,
 		connectorService: connService,
@@ -277,6 +280,7 @@ func (r *Runtime) Run(ctx context.Context) (err error) {
 		r.logger.Info(ctx).Send()
 	}
 
+	close(r.Ready)
 	return nil
 }