(t *testing.T, meter view.Meter, requestType string, code codes.Code, expected int64)
| 547 | } |
| 548 | |
| 549 | func assertResponseReceiveMetricsSameCode(t *testing.T, meter view.Meter, requestType string, code codes.Code, expected int64) []*view.Row { |
| 550 | t.Helper() |
| 551 | rows, err := meter.RetrieveData(serviceInvocationResponseRecvName) |
| 552 | require.NoError(t, err) |
| 553 | assert.Len(t, rows, 1) |
| 554 | count := diag.GetCountValueForObservationWithTagSet( |
| 555 | rows, map[tag.Tag]bool{ |
| 556 | diag.NewTag("status", strconv.Itoa(int(code))): true, |
| 557 | diag.NewTag("type", requestType): true, |
| 558 | }) |
| 559 | assert.Equal(t, expected, count) |
| 560 | return rows |
| 561 | } |
| 562 | |
| 563 | func assertRequestSentMetrics(t *testing.T, meter view.Meter, requestType string, requestsSentExpected int64, assertEqualFn func(t assert.TestingT, e1 any, e2 any, msgAndArgs ...any) bool) []*view.Row { |
| 564 | t.Helper() |
no test coverage detected