Function newForwarder

modules/distributor/forwarder/otlpgrpc/forwarder_test.go:28–39

(t *testing.T, cfg Config, logger log.Logger)

}

func newForwarder(t *testing.T, cfg Config, logger log.Logger) *Forwarder {
	t.Helper()

	f, err := NewForwarder(cfg, logger)
	require.NoError(t, err)

	t.Cleanup(func() {
		require.NoError(t, f.Shutdown(context.Background()))
	})

	return f
}

func newListener(t *testing.T, srv ptraceotlp.GRPCServer) *bufconn.Listener {
	t.Helper()