Add rpc.service for the destination.service.resource calculation (#160)

Author: gregkalapos

enrichments/trace/internal/elastic/span.go

@@ -463,6 +463,9 @@ func (s *spanEnrichmentContext) setDestinationService(span ptrace.Span) {
 				s.serverAddress, s.serverPort, // fallback
 			); res != "" {
 				destnResource = res
+			} else {
+				// fallback to RPC service
+				destnResource = s.rpcService
 			}
 		}
 	}

enrichments/trace/internal/elastic/span_test.go

@@ -938,6 +938,33 @@ func TestElasticSpanEnrich(t *testing.T) {
 				elasticattr.SuccessCount:            int64(1),
 			},
 		},
+		{
+			name: "rpc_span_with_only_rpc_sevice_attr",
+			input: func() ptrace.Span {
+				span := getElasticSpan()
+				span.SetName("testspan")
+				// rpc.service should be used as destination.service.resource
+				// if no other attributes are present.
+				span.Attributes().PutStr(semconv25.AttributeRPCService, "myService")
+				span.Attributes().PutStr(semconv25.AttributeRPCSystem, "grpc")
+				return span
+			}(),
+			config: config.Enabled().Span,
+			enrichedAttrs: map[string]any{
+				elasticattr.TimestampUs:                    startTs.AsTime().UnixMicro(),
+				elasticattr.SpanName:                       "testspan",
+				elasticattr.ProcessorEvent:                 "span",
+				elasticattr.SpanRepresentativeCount:        float64(1),
+				elasticattr.SpanType:                       "external",
+				elasticattr.SpanSubtype:                    "grpc",
+				elasticattr.SpanDurationUs:                 expectedDuration.Microseconds(),
+				elasticattr.EventOutcome:                   "success",
+				elasticattr.SuccessCount:                   int64(1),
+				elasticattr.ServiceTargetType:              "grpc",
+				elasticattr.ServiceTargetName:              "myService",
+				elasticattr.SpanDestinationServiceResource: "myService",
+			},
+		},
 	} {
 		t.Run(tc.name, func(t *testing.T) {
 			expectedSpan := ptrace.NewSpan()