Make write async

rookie-ninja · Jan 30, 2022 · 5c841b5 · 5c841b5
1 parent 86ee807
commit 5c841b5
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/syncer_loki.go b/syncer_loki.go
@@ -292,10 +292,11 @@ type lokiStreamList struct {
 
 // Write to logChannel
 func (syncer *LokiSyncer) Write(p []byte) (n int, err error) {
-	syncer.logChannel <- &lokiValue{
-		Values: []string{fmt.Sprintf("%d", time.Now().UnixNano()), string(p)},
-	}
-
+	go func() {
+		syncer.logChannel <- &lokiValue{
+			Values: []string{fmt.Sprintf("%d", time.Now().UnixNano()), string(p)},
+		}
+	}()
 	return len(p), nil
 }