expose grpc(default) when using otelarrow as exporter

Signed-off-by: Praful Khanduri <holiodin@gmail.com>

Author: Horiodino

.chloggen/expose_grpc_otelarrow.yaml

@@ -0,0 +1,17 @@
+# One of 'breaking', 'deprecation', 'new_component', 'enhancement', 'bug_fix'
+change_type: enhancement
+
+# The name of the component, or a single word describing the area of concern, (e.g. collector, target allocator, auto-instrumentation, opamp, github action)
+component: collector
+
+# A brief description of the change. Surround your text with quotes ("") if it needs to start with a backtick (`).
+note: "Expose the default gRPC receiver port (4317) for otelarrow and automatically apply grpc protocol defaults when protocols are omitted or otelarrow is enabled."
+
+
+# One or more tracking issues related to the change
+issues: [4713]
+
+# (Optional) One or more lines of additional information to render under the primary note.
+# These lines will be padded with 2 spaces and then inserted directly into the document.
+# Use pipe (|) for multiline entries.
+subtext:

apis/v1beta1/config_test.go

@@ -732,10 +732,11 @@ func TestConfig_getEnvironmentVariablesForComponentKinds(t *testing.T) {
 
 func TestConfig_GetReceiverPorts(t *testing.T) {
 	tests := []struct {
-		name    string
-		file    string
-		want    []v1.ServicePort
-		wantErr bool
+		name          string
+		file          string
+		want          []v1.ServicePort
+		wantErr       bool
+		applyDefaults bool
 	}{
 		{
 			name: "k8sevents",
@@ -788,6 +789,33 @@ func TestConfig_GetReceiverPorts(t *testing.T) {
 				},
 			},
 		},
+		{
+			name: "otelarrow",
+			file: "testdata/otelcol-otelarrow.yaml",
+			want: []v1.ServicePort{
+				{
+					Name:        "otelarrow-grpc",
+					Protocol:    "",
+					AppProtocol: ptr.To("grpc"),
+					Port:        4317,
+					TargetPort:  intstr.FromInt32(4317),
+				},
+			},
+		},
+		{
+			name:          "otelarrow missing protocols",
+			file:          "testdata/otelcol-otelarrow-no-protocols.yaml",
+			applyDefaults: true,
+			want: []v1.ServicePort{
+				{
+					Name:        "otelarrow-grpc",
+					Protocol:    "",
+					AppProtocol: ptr.To("grpc"),
+					Port:        4317,
+					TargetPort:  intstr.FromInt32(4317),
+				},
+			},
+		},
 		{
 			name: "filelog",
 			file: "testdata/otelcol-filelog.yaml",
@@ -807,6 +835,10 @@ func TestConfig_GetReceiverPorts(t *testing.T) {
 			c := &Config{}
 			err = go_yaml.Unmarshal(collectorYaml, c)
 			require.NoError(t, err)
+			if tt.applyDefaults {
+				_, err = c.ApplyDefaults(logr.Discard())
+				require.NoError(t, err)
+			}
 			ports, err := c.GetReceiverPorts(logr.Discard())
 			if tt.wantErr {
 				require.Error(t, err)

apis/v1beta1/testdata/otelcol-otelarrow-no-protocols.yaml

@@ -0,0 +1,11 @@
+receivers:
+  otelarrow: {}
+
+exporters:
+  debug:
+
+service:
+  pipelines:
+    traces:
+      receivers: [otelarrow]
+      exporters: [debug]

apis/v1beta1/testdata/otelcol-otelarrow.yaml

@@ -0,0 +1,13 @@
+receivers:
+  otelarrow:
+    protocols:
+      grpc:
+
+exporters:
+  debug:
+
+service:
+  pipelines:
+    traces:
+      receivers: [otelarrow]
+      exporters: [debug]

internal/components/multi_endpoint.go

@@ -77,8 +77,15 @@ func (m *MultiPortReceiver) GetDefaultConfig(logger logr.Logger, config any, opt
 	if err := mapstructure.Decode(config, multiProtoEndpointCfg); err != nil {
 		return nil, err
 	}
+	protocols := multiProtoEndpointCfg.Protocols
+	if len(protocols) == 0 {
+		protocols = map[string]*SingleEndpointConfig{}
+		for protocol := range m.portMappings {
+			protocols[protocol] = nil
+		}
+	}
 	defaultedConfig := map[string]any{}
-	for protocol, ec := range multiProtoEndpointCfg.Protocols {
+	for protocol, ec := range protocols {
 		defaultSvc, ok := m.portMappings[protocol]
 		if !ok {
 			return nil, fmt.Errorf("unknown protocol set: %s", protocol)

internal/components/receivers/helpers.go

@@ -72,6 +72,11 @@ var componentParsers = []components.Parser{
 			WithTargetPort(3100).
 			WithAppProtocol(&components.HttpProtocol)).
 		MustBuild(),
+	components.NewMultiPortReceiverBuilder("otelarrow").
+		AddPortMapping(components.NewProtocolBuilder("grpc", 4317).
+			WithAppProtocol(&components.GrpcProtocol).
+			WithTargetPort(4317)).
+		MustBuild(),
 	components.NewSinglePortParserBuilder("awsxray", 2000).
 		WithTargetPort(2000).
 		WithProtocol(corev1.ProtocolUDP).