Function TestShim_integration

modules/distributor/receiver/shim_test.go:39–149

These tests use the OpenTelemetry Collector Exporters to validate the different protocols

(t *testing.T)

// These tests use the OpenTelemetry Collector Exporters to validate the different protocols
func TestShim_integration(t *testing.T) {
	randomTraces := testdata.GenerateTraces(5)
	var headers configopaque.MapList
	headers.Set(generator.NoGenerateMetricsContextKey, "true")

	testCases := []struct {
		name              string
		receiverCfg       map[string]interface{}
		factory           exporter.Factory
		exporterCfg       component.Config
		expectedTransport string
	}{
		{
			name: "otlpexporter",
			receiverCfg: map[string]interface{}{
				"otlp": map[string]interface{}{
					"protocols": map[string]interface{}{
						"grpc": nil,
					},
				},
			},
			factory: otlpexporter.NewFactory(),
			exporterCfg: &otlpexporter.Config{
				ClientConfig: configgrpc.ClientConfig{
					Endpoint: "127.0.0.1:4317",
					TLS: configtls.ClientConfig{
						Insecure: true,
					},
					Headers: headers,
				},
			},
			expectedTransport: "grpc",
		},
		{
			name: "otlphttpexporter - JSON encoding",
			receiverCfg: map[string]interface{}{
				"otlp": map[string]interface{}{
					"protocols": map[string]interface{}{
						"http": nil,
					},
				},
			},
			factory: otlphttpexporter.NewFactory(),
			exporterCfg: &otlphttpexporter.Config{
				ClientConfig: confighttp.ClientConfig{
					Endpoint: "http://127.0.0.1:4318",
					Headers:  headers,
				},
				Encoding: otlphttpexporter.EncodingJSON,
			},
			expectedTransport: "http",
		},
		{
			name: "otlphttpexporter - proto encoding",
			receiverCfg: map[string]interface{}{
				"otlp": map[string]interface{}{
					"protocols": map[string]interface{}{
						"http": nil,