helper function

cmd/conduit/main.go

@@ -50,11 +50,7 @@ func init() {
 
 // runConduitCmdWithConfig run the main logic with a supplied conduit config
 func runConduitCmdWithConfig(cfg *conduit.Config) error {
-	defer func() {
-		if r := recover(); r != nil {
-			logger.Fatalf("conduit framework experienced a panic: %v", r)
-		}
-	}()
+	defer conduit.HandlePanic(logger)
 
 	// From docs:
 	// BindEnv takes one or more parameters. The first parameter is the key name, the rest are the name of the

conduit/common.go

@@ -0,0 +1,10 @@
+package conduit
+
+import log "github.com/sirupsen/logrus"
+
+// HandlePanic function to log panics in a common way
+func HandlePanic(logger *log.Logger) {
+	if r := recover(); r != nil {
+		logger.Panicf("conduit pipeline experienced a panic: %v", r)
+	}
+}

conduit/pipeline.go

@@ -293,11 +293,7 @@ func (p *pipelineImpl) Start() {
 	go func() {
 		defer p.wg.Done()
 		// We need to add a separate recover function here since it launches its own go-routine
-		defer func() {
-			if r := recover(); r != nil {
-				p.logger.Fatalf("conduit pipeline experienced a panic: %v", r)
-			}
-		}()
+		defer HandlePanic(p.logger)
 		for {
 		pipelineRun:
 			select {