(t *testing.T)
| 406 | } |
| 407 | |
| 408 | func TestProtoMultiMessageDecoder(t *testing.T) { |
| 409 | data, err := os.ReadFile("testdata/protobuf-multimessage") |
| 410 | require.NoErrorf(t, err, "Reading file failed: %v", err) |
| 411 | |
| 412 | buf := bytes.NewReader(data) |
| 413 | decoder := NewDecoder(buf, FmtProtoDelim) |
| 414 | var metrics []*dto.MetricFamily |
| 415 | for { |
| 416 | var mf dto.MetricFamily |
| 417 | if err := decoder.Decode(&mf); err != nil { |
| 418 | if errors.Is(err, io.EOF) { |
| 419 | break |
| 420 | } |
| 421 | t.Fatalf("Unmarshalling failed: %v", err) |
| 422 | } |
| 423 | metrics = append(metrics, &mf) |
| 424 | } |
| 425 | |
| 426 | require.Lenf(t, metrics, 6, "Expected %d metrics but got %d!", 6, len(metrics)) |
| 427 | } |
| 428 | |
| 429 | func testDiscriminatorHTTPHeader(t testing.TB) { |
| 430 | scenarios := []struct { |
nothing calls this directly
no test coverage detected