(t *testing.T, meter view.Meter, requestType string, requestsSentExpected int64, assertEqualFn func(t assert.TestingT, e1 any, e2 any, msgAndArgs ...any) bool)
| 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() |
| 565 | rows, err := meter.RetrieveData(serviceInvocationRequestSentName) |
| 566 | require.NoError(t, err) |
| 567 | assert.Len(t, rows, 1) |
| 568 | requestsSent := diag.GetCountValueForObservationWithTagSet( |
| 569 | rows, map[tag.Tag]bool{diag.NewTag("type", requestType): true}) |
| 570 | |
| 571 | if assertEqualFn == nil { |
| 572 | assertEqualFn = assert.Equal |
| 573 | } |
| 574 | assertEqualFn(t, requestsSent, requestsSentExpected) |
| 575 | return rows |
| 576 | } |
| 577 | |
| 578 | func (s *proxyTestSuite) TestResiliencyStreaming() { |
| 579 | // Set the resiliency policy |
no test coverage detected