From 77f251bbb51e8ec8ef67b946a9ae1ffc775cd60b Mon Sep 17 00:00:00 2001
From: bwplotka <bwplotka@gmail.com>
Date: Wed, 17 Dec 2025 03:42:08 +0000
Subject: [PATCH] chore(scrape): add scrapeLoop.scrapeAndReport test and
 benchmark

Signed-off-by: bwplotka <bwplotka@gmail.com>
---
 scrape/scrape_test.go | 54 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 54 insertions(+)

diff --git a/scrape/scrape_test.go b/scrape/scrape_test.go
index eab1499158..cc13a5d7fa 100644
--- a/scrape/scrape_test.go
+++ b/scrape/scrape_test.go
@@ -1596,6 +1596,60 @@ func BenchmarkScrapeLoopAppend(b *testing.B) {
 	}
 }
 
+func TestScrapeLoopScrapeAndReport(t *testing.T) {
+	parsableText := readTextParseTestMetrics(t)
+
+	capp := &collectResultAppender{}
+	scraper := &testScraper{
+		scrapeFunc: func(ctx context.Context, writer io.Writer) error {
+			_, err := writer.Write(parsableText)
+			return err
+		},
+	}
+
+	sl := newBasicScrapeLoop(t, context.Background(), scraper, func(context.Context) storage.Appender { return capp }, 0)
+	sl.fallbackScrapeProtocol = "application/openmetrics-text"
+
+	ts := time.Time{}
+
+	sl.scrapeAndReport(time.Time{}, ts, nil)
+	require.NoError(t, scraper.lastError)
+
+	require.Len(t, capp.resultFloats, 1862)
+	require.Len(t, capp.resultHistograms, 0)
+	require.Len(t, capp.resultMetadata, 1862)
+	require.Len(t, capp.resultExemplars, 0)
+}
+
+// Recommended CLI invocation:
+/*
+	export bench=scrapeAndReport-v1 && go test ./scrape/... \
+		-run '^$' -bench '^BenchmarkScrapeLoopScrapeAndReport' \
+		-benchtime 5s -count 6 -cpu 2 -timeout 999m \
+		| tee ${bench}.txt
+*/
+func BenchmarkScrapeLoopScrapeAndReport(b *testing.B) {
+	parsableText := readTextParseTestMetrics(b)
+
+	_, sl := simpleTestScrapeLoop(b)
+	sl.fallbackScrapeProtocol = "application/openmetrics-text"
+	scraper := &testScraper{scrapeFunc: func(ctx context.Context, writer io.Writer) error {
+		_, err := writer.Write(parsableText)
+		return err
+	}}
+	sl.scraper = scraper
+
+	ts := time.Time{}
+
+	b.ReportAllocs()
+	b.ResetTimer()
+	for b.Loop() {
+		ts = ts.Add(time.Second)
+		sl.scrapeAndReport(time.Time{}, ts, nil)
+		require.NoError(b, scraper.lastError)
+	}
+}
+
 func TestSetOptionsHandlingStaleness(t *testing.T) {
 	s := teststorage.New(t, 600000)
 	defer s.Close()