support debug mode for logs collecting

flashcatcloud · Dec 4, 2023 · bcb6494 · bcb6494
1 parent dc8edde
commit bcb6494
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/logs/processor/processor.go b/logs/processor/processor.go
@@ -9,9 +9,12 @@ package processor
 
 import (
 	"context"
+	"fmt"
 	"log"
+	"os"
 	"sync"
 
+	coreconfig "flashcat.cloud/categraf/config"
 	logsconfig "flashcat.cloud/categraf/config/logs"
 	"flashcat.cloud/categraf/logs/diagnostic"
 	"flashcat.cloud/categraf/logs/message"
@@ -94,6 +97,9 @@ func (p *Processor) processMessage(msg *message.Message) {
 			log.Println("unable to encode msg ", err)
 			return
 		}
+		if coreconfig.Config.DebugMode {
+			fmt.Fprintf(os.Stdout, "D! log item: %s", string(content))
+		}
 		msg.Content = content
 		p.outputChan <- msg
 	}