[chore] add generated tests for receivers (#29682)

Continuation of the work on
#27849
- now opening a way to create lifecycle tests for receivers.

Author: atoulme

cmd/mdatagen/templates/component_test.go.tmpl

@@ -18,10 +18,16 @@ import (
 	"go.opentelemetry.io/collector/consumer/consumertest"
 	"go.opentelemetry.io/collector/processor"
 	"go.opentelemetry.io/collector/processor/processortest"
+{{ end }}
+{{ if isReceiver }}
+	"go.opentelemetry.io/collector/consumer/consumertest"
+	"go.opentelemetry.io/collector/receiver"
+	"go.opentelemetry.io/collector/receiver/receivertest"
 {{ end }}
 	"go.opentelemetry.io/collector/confmap/confmaptest"
-
+{{ if or (isExporter) (isProcessor) }}
 	"github.com/open-telemetry/opentelemetry-collector-contrib/internal/coreinternal/testdata"
+{{ end }}
 )
 
 // assertNoErrorHost implements a component.Host that asserts that there were no errors.
@@ -224,3 +230,72 @@ func Test_ComponentLifecycle(t *testing.T) {
 	}
 }
 {{ end }}
+
+{{ if isReceiver }}
+func Test_ComponentLifecycle(t *testing.T) {
+	factory := NewFactory()
+
+	tests := []struct{
+		name string
+		createFn func(ctx context.Context, set receiver.CreateSettings, cfg component.Config) (component.Component, error)
+	}{
+{{ if supportsLogs }}
+		{
+			name: "logs",
+			createFn: func(ctx context.Context, set receiver.CreateSettings, cfg component.Config) (component.Component, error) {
+				return factory.CreateLogsReceiver(ctx, set, cfg, consumertest.NewNop())
+			},
+		},
+{{ end }}
+{{ if supportsMetrics }}
+		{
+			name: "metrics",
+			createFn: func(ctx context.Context, set receiver.CreateSettings, cfg component.Config) (component.Component, error) {
+				return factory.CreateMetricsReceiver(ctx, set, cfg, consumertest.NewNop())
+			},
+		},
+{{ end }}
+{{ if supportsTraces }}
+		{
+			name: "traces",
+			createFn: func(ctx context.Context, set receiver.CreateSettings, cfg component.Config) (component.Component, error) {
+				return factory.CreateTracesReceiver(ctx, set, cfg, consumertest.NewNop())
+			},
+		},
+{{ end }}
+	}
+
+	cm, err := confmaptest.LoadConf("metadata.yaml")
+	require.NoError(t, err)
+	cfg := factory.CreateDefaultConfig()
+	sub, err := cm.Sub("tests::config")
+	require.NoError(t, err)
+	require.NoError(t, component.UnmarshalConfig(sub, cfg))
+
+	for _, test := range tests {
+		t.Run(test.name + "-shutdown", func(t *testing.T) {
+			c, err := test.createFn(context.Background(), receivertest.NewNopCreateSettings(), cfg)
+			require.NoError(t, err)
+			err = c.Shutdown(context.Background())
+			require.NoError(t, err)
+		})
+
+		t.Run(test.name + "-lifecycle", func(t *testing.T) {
+			{{ if skipLifecycle }}
+			// TODO support lifecycle
+			t.SkipNow()
+			{{ end }}
+			firstRcvr, err := test.createFn(context.Background(), receivertest.NewNopCreateSettings(), cfg)
+			require.NoError(t, err)
+			host := newAssertNoErrorHost(t)
+			require.NoError(t, err)
+			require.NoError(t, firstRcvr.Start(context.Background(), host))
+			require.NoError(t, firstRcvr.Shutdown(context.Background()))
+			secondRcvr, err := test.createFn(context.Background(), receivertest.NewNopCreateSettings(), cfg)
+			require.NoError(t, err)
+			require.NoError(t, secondRcvr.Start(context.Background(), host))
+			require.NoError(t, secondRcvr.Shutdown(context.Background()))
+		})
+	}
+}
+{{ end }}

receiver/splunkhecreceiver/generated_component_test.go

@@ -8,3 +8,5 @@ status:
   codeowners:
     active: ["atoulme"]
     emeritus:
+tests:
+  config:

receiver/splunkhecreceiver/metadata.yaml

@@ -456,7 +456,7 @@ func Test_splunkhecReceiver_TLS(t *testing.T) {
 		require.NoError(t, r.Shutdown(context.Background()))
 	}()
 
-	mh := newAssertNoErrorHost(t)
+	mh := newAssertNoErrHost(t)
 	require.NoError(t, r.Start(context.Background(), mh), "should not have failed to start log reception")
 	require.NoError(t, r.Start(context.Background(), mh), "should not fail to start log on second Start call")
 
@@ -898,21 +898,21 @@ func (b badReqBody) Close() error {
 	return nil
 }
 
-// assertNoErrorHost implements a component.Host that asserts that there were no errors.
-type assertNoErrorHost struct {
+// assertNoErrHost implements a component.Host that asserts that there were no errors.
+type assertNoErrHost struct {
 	component.Host
 	*testing.T
 }
 
-// newAssertNoErrorHost returns a new instance of assertNoErrorHost.
-func newAssertNoErrorHost(t *testing.T) component.Host {
-	return &assertNoErrorHost{
+// newAssertNoErrHost returns a new instance of assertNoErrHost.
+func newAssertNoErrHost(t *testing.T) component.Host {
+	return &assertNoErrHost{
 		Host: componenttest.NewNopHost(),
 		T:    t,
 	}
 }
 
-func (aneh *assertNoErrorHost) ReportFatalError(err error) {
+func (aneh *assertNoErrHost) ReportFatalError(err error) {
 	assert.NoError(aneh, err)
 }