MCPcopy
hub / github.com/prometheus/client_golang / testToReader

Function testToReader

prometheus/graphite/bridge_test.go:251–296  ·  view source on GitHub ↗
(t *testing.T, useTags bool)

Source from the content-addressed store, hash-verified

249}
250
251func testToReader(t *testing.T, useTags bool) {
252 cntVec := prometheus.NewCounterVec(
253 prometheus.CounterOpts{
254 Name: "name",
255 Help: "docstring",
256 ConstLabels: prometheus.Labels{"constname": "constvalue"},
257 },
258 []string{"labelname"},
259 )
260 cntVec.WithLabelValues("val1").Inc()
261 cntVec.WithLabelValues("val2").Inc()
262
263 reg := prometheus.NewRegistry()
264 reg.MustRegister(cntVec)
265
266 var (
267 want = `prefix.name.constname.constvalue.labelname.val1 1 1477043
268prefix.name.constname.constvalue.labelname.val2 1 1477043
269`
270 wantTagged = `prefix.name;constname=constvalue;labelname=val1 1 1477043
271prefix.name;constname=constvalue;labelname=val2 1 1477043
272`
273 )
274
275 if useTags {
276 want = wantTagged
277 }
278
279 mfs, err := reg.Gather()
280 if err != nil {
281 t.Fatalf("error: %v", err)
282 }
283
284 now := model.Time(1477043083)
285 var buf bytes.Buffer
286 err = writeMetrics(&buf, mfs, useTags, "prefix", now)
287 if err != nil {
288 t.Fatalf("error: %v", err)
289 }
290
291 got := buf.String()
292
293 if err := checkLinesAreEqual(want, got, useTags); err != nil {
294 t.Fatal(err.Error())
295 }
296}
297
298func checkLinesAreEqual(w, g string, useTags bool) error {
299 if useTags {

Callers 1

TestToReaderFunction · 0.85

Calls 10

WithLabelValuesMethod · 0.95
MustRegisterMethod · 0.95
GatherMethod · 0.95
NewCounterVecFunction · 0.92
NewRegistryFunction · 0.92
writeMetricsFunction · 0.85
checkLinesAreEqualFunction · 0.85
IncMethod · 0.65
StringMethod · 0.45
ErrorMethod · 0.45

Tested by

no test coverage detected