Function TestMetricsScraperScrapeServerError

internal/metrics/scraper_test.go:283–296

(t *testing.T)

}

func TestMetricsScraperScrapeServerError(t *testing.T) {
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		http.Error(w, "internal error", http.StatusInternalServerError)
	}))
	defer server.Close()

	scraper := NewMetricsScraper(ScraperSettings{
		Port:       serverPort(t, server),
		BufferSize: 10,
	})

	scraper.Scrape(context.Background())
	assert.Error(t, scraper.LastError())
}

func TestMetricsScraperScrapeServerUnavailable(t *testing.T) {
	server := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {}))