github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-09 12:07:47 +00:00
Code Issues Projects Releases Wiki Activity

clean up testutil/metrics content

Browse Source 
including:
1. use constant var MetricNameLabel to replace model.MetricNameLabel in ParseMetrics
2. remove function ExtractMetricSamples
This commit is contained in:
jornshen 2020-08-31 21:21:54 +08:00
parent e23d83eead
commit 9c8867f7a8
1 changed files with 1 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
staging/src/k8s.io/component-base/metrics/testutil/metrics.go
View File

@ -86,7 +86,7 @@ func ParseMetrics(data string, output *Metrics) error {
continue continue
} }
for _, metric := range v { for _, metric := range v {
name := string(metric.Metric[model.MetricNameLabel]) name := string(metric.Metric[MetricNameLabel])
(*output)[name] = append((*output)[name], metric) (*output)[name] = append((*output)[name], metric)
} }
} }
@ -101,28 +101,6 @@ func TextToMetricFamilies(in io.Reader) (map[string]*dto.MetricFamily, error) {
return textParser.TextToMetricFamilies(in) return textParser.TextToMetricFamilies(in)
} }
// ExtractMetricSamples parses the prometheus metric samples from the input string.
func ExtractMetricSamples(metricsBlob string) ([]*model.Sample, error) {
dec := expfmt.NewDecoder(strings.NewReader(metricsBlob), expfmt.FmtText)
decoder := expfmt.SampleDecoder{
Dec: dec,
Opts: &expfmt.DecodeOptions{},
}
var samples []*model.Sample
for {
var v model.Vector
if err := decoder.Decode(&v); err != nil {
if err == io.EOF {
// Expected loop termination condition.
return samples, nil
}
return nil, err
}
samples = append(samples, v...)
}
}
// PrintSample returns formatted representation of metric Sample // PrintSample returns formatted representation of metric Sample
func PrintSample(sample *model.Sample) string { func PrintSample(sample *model.Sample) string {
buf := make([]string, 0) buf := make([]string, 0)