logs when queue is full (#570)

flashcatcloud · Jul 13, 2023 · 1e9e32f · 1e9e32f
1 parent e6e7bd9
commit 1e9e32f
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/writer/writers.go b/writer/writers.go
@@ -2,6 +2,7 @@ package writer
 
 import (
 	"fmt"
+	"log"
 	"sort"
 	"strings"
 	"sync"
@@ -100,7 +101,10 @@ func WriteSamples(samples []*types.Sample) {
 		}
 		items = append(items, item)
 	}
-	writers.queue.PushFrontN(items)
+	flag := writers.queue.PushFrontN(items)
+	if !flag {
+		log.Printf("E! write %d samples failed, please increase queue size(%d)", len(items), writers.queue.Len())
+	}
 }
 
 // WriteTimeSeries write prompb.TimeSeries to all writers