github-mirrors/VictoriaMetrics
1
0
Fork 0
mirror of https://github.com/VictoriaMetrics/VictoriaMetrics.git synced 2025-03-11 15:34:56 +00:00
Code Issues Projects Releases Packages Wiki Activity

app/vmselect/prometheus: make more clear log messages for errors during sending data to remote clients

Browse source
This commit is contained in:
Aliaksandr Valialkin 2021-09-16 12:56:58 +03:00
parent 7d910c6a51
commit a4eaf1a0a1
1 changed files with 17 additions and 17 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

34
app/vmselect/prometheus/prometheus.go
View file

@ -105,7 +105,7 @@ func FederateHandler(startTime time.Time, at *auth.Token, w http.ResponseWriter,
return err
})
if err != nil {
return fmt.Errorf("error during data fetching: %w", err)
return fmt.Errorf("error during sending data to remote client: %w", err)
}
if err := bw.Flush(); err != nil {
return err
@ -182,7 +182,7 @@ func ExportCSVHandler(startTime time.Time, at *auth.Token, w http.ResponseWriter
}
err = <-doneCh
if err != nil {
return fmt.Errorf("error during exporting data to csv: %w", err)
return fmt.Errorf("error during sending the exported csv data to remote client: %w", err)
}
return nil
}
@ -251,10 +251,10 @@ func ExportNativeHandler(startTime time.Time, at *auth.Token, w http.ResponseWri
return err
})
if err != nil {
return err
return fmt.Errorf("error during sending native data to remote client: %w", err)
}
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("error during flushing native data to remote client: %w", err)
}
return nil
}
@ -424,7 +424,7 @@ func exportHandler(at *auth.Token, w http.ResponseWriter, r *http.Request, match
}
err = <-doneCh
if err != nil {
return fmt.Errorf("error during data fetching: %w", err)
return fmt.Errorf("error during sending the data to remote client: %w", err)
}
return nil
}
@ -595,7 +595,7 @@ func LabelValuesHandler(startTime time.Time, at *auth.Token, labelName string, w
defer bufferedwriter.Put(bw)
WriteLabelValuesResponse(bw, isPartial, labelValues)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("canot flush label values to remote client: %w", err)
}
return nil
}
@ -661,7 +661,7 @@ func labelValuesWithMatches(at *auth.Token, denyPartialResponse bool, labelName
return nil
})
if err != nil {
return nil, false, fmt.Errorf("error when data fetching: %w", err)
return nil, false, fmt.Errorf("cannot fetch label values from storage: %w", err)
}
}
labelValues := make([]string, 0, len(m))
@ -690,7 +690,7 @@ func LabelsCountHandler(startTime time.Time, at *auth.Token, w http.ResponseWrit
defer bufferedwriter.Put(bw)
WriteLabelsCountResponse(bw, isPartial, labelEntries)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot send labels count response to remote client: %w", err)
}
return nil
}
@ -761,7 +761,7 @@ func TSDBStatusHandler(startTime time.Time, at *auth.Token, w http.ResponseWrite
defer bufferedwriter.Put(bw)
WriteTSDBStatusResponse(bw, isPartial, status)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot send tsdb status response to remote client: %w", err)
}
return nil
}
@ -857,7 +857,7 @@ func LabelsHandler(startTime time.Time, at *auth.Token, w http.ResponseWriter, r
defer bufferedwriter.Put(bw)
WriteLabelsResponse(bw, isPartial, labels)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot send labels response to remote client: %w", err)
}
return nil
}
@ -909,7 +909,7 @@ func labelsWithMatches(at *auth.Token, denyPartialResponse bool, matches []strin
return nil
})
if err != nil {
return nil, false, fmt.Errorf("error when data fetching: %w", err)
return nil, false, fmt.Errorf("cannot fetch labels from storage: %w", err)
}
}
labels := make([]string, 0, len(m))
@ -938,7 +938,7 @@ func SeriesCountHandler(startTime time.Time, at *auth.Token, w http.ResponseWrit
defer bufferedwriter.Put(bw)
WriteSeriesCountResponse(bw, isPartial, n)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot send series count response to remote client: %w", err)
}
return nil
}
@ -1031,11 +1031,11 @@ func SeriesHandler(startTime time.Time, at *auth.Token, w http.ResponseWriter, r
// WriteSeriesResponse must consume all the data from resultsCh.
WriteSeriesResponse(bw, isPartial, resultsCh)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot flush series response to remote client: %w", err)
}
err = <-doneCh
if err != nil {
return fmt.Errorf("error during data fetching: %w", err)
return fmt.Errorf("cannot send series response to remote client: %w", err)
}
return nil
}
@ -1152,7 +1152,7 @@ func QueryHandler(startTime time.Time, at *auth.Token, w http.ResponseWriter, r
defer bufferedwriter.Put(bw)
WriteQueryResponse(bw, ec.IsPartialResponse, result)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot flush query response to remote client: %w", err)
}
return nil
}
@ -1248,7 +1248,7 @@ func queryRangeHandler(startTime time.Time, at *auth.Token, w http.ResponseWrite
defer bufferedwriter.Put(bw)
WriteQueryRangeResponse(bw, ec.IsPartialResponse, result)
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot send query range response to remote client: %w", err)
}
return nil
}
@ -1432,7 +1432,7 @@ func QueryStatsHandler(startTime time.Time, at *auth.Token, w http.ResponseWrite
querystats.WriteJSONQueryStatsForAccountProject(bw, topN, at.AccountID, at.ProjectID, maxLifetime)
}
if err := bw.Flush(); err != nil {
return err
return fmt.Errorf("cannot send query stats response to client: %w", err)
}
return nil
}