Function newAssertingConsumer

modules/distributor/receiver/middleware_test.go:28–33

(t *testing.T, assertFunc assertFunc)

}

func newAssertingConsumer(t *testing.T, assertFunc assertFunc) consumer.Traces {
	return &testConsumer{
		t:          t,
		assertFunc: assertFunc,
	}
}

func (tc *testConsumer) ConsumeTraces(ctx context.Context, _ ptrace.Traces) error {
	tc.assertFunc(tc.t, ctx)