Function TestReceivers

integration/operations/receivers_test.go:33–195

(t *testing.T)

const configReceivers = `config-receivers.yaml`

func TestReceivers(t *testing.T) {
	util.RunIntegrationTests(t, util.TestHarnessConfig{
		DeploymentMode: util.DeploymentModeSingleBinary,
		ConfigOverlay:  configReceivers,
	}, func(h *util.TempoHarness) {
		h.WaitTracesWritable(t)

		testReceivers := []struct {
			name           string
			createExporter func() (exporter.Traces, error)
		}{
			{
				name: "otlp gRPC",
				createExporter: func() (exporter.Traces, error) {
					factory := otlpexporter.NewFactory()
					cfg := factory.CreateDefaultConfig().(*otlpexporter.Config)
					cfg.ClientConfig = configgrpc.ClientConfig{
						Endpoint: h.Services[util.ServiceDistributor].Endpoint(4317),
						TLS: configtls.ClientConfig{
							Insecure: true,
						},
					}

					logger, _ := zap.NewDevelopment()
					return factory.CreateTraces(
						context.Background(),
						exporter.Settings{
							ID: component.NewID(factory.Type()),
							TelemetrySettings: component.TelemetrySettings{
								Logger:         logger,
								TracerProvider: tracenoop.NewTracerProvider(),
								MeterProvider:  metricnoop.NewMeterProvider(),
							},
							BuildInfo: component.NewDefaultBuildInfo(),
						},
						cfg,
					)
				},
			},
			{
				name: "otlp HTTP",
				createExporter: func() (exporter.Traces, error) {
					factory := otlphttpexporter.NewFactory()
					cfg := factory.CreateDefaultConfig().(*otlphttpexporter.Config)
					cfg.ClientConfig = confighttp.ClientConfig{
						Endpoint: "http://" + h.Services[util.ServiceDistributor].Endpoint(4318),
						TLS: configtls.ClientConfig{
							Insecure: true,
						},
					}

					logger, _ := zap.NewDevelopment()
					return factory.CreateTraces(
						context.Background(),
						exporter.Settings{
							ID: component.NewID(factory.Type()),
							TelemetrySettings: component.TelemetrySettings{
								Logger:         logger,