Remove the proto dependency in goldendataset for traces

CHANGELOG.md

@@ -12,6 +12,7 @@
 ## 💡 Enhancements 💡
 
 - Add `doc.go` files to the consumer package and its subpackages (#3270)
+- Remove the proto dependency in `goldendataset` for traces (#TBD)
 
 ## v0.27.0 Beta
 

consumer/pdata/common.go

@@ -354,6 +354,10 @@ func NewAttributeMap() AttributeMap {
 	return AttributeMap{&orig}
 }
 
+func NewAttributeMapFromKeyValues(orig *[]otlpcommon.KeyValue) AttributeMap {
+	return newAttributeMap(orig)
+}
+
 func newAttributeMap(orig *[]otlpcommon.KeyValue) AttributeMap {
 	return AttributeMap{orig}
 }

internal/goldendataset/generator_commons.go

@@ -22,7 +22,7 @@ import (
 
 	"github.com/spf13/cast"
 
-	"go.opentelemetry.io/collector/internal/data"
+	"go.opentelemetry.io/collector/consumer/pdata"
 	otlpcommon "go.opentelemetry.io/collector/internal/data/protogen/common/v1"
 )
 
@@ -94,20 +94,20 @@ func loadPictOutputFile(fileName string) ([][]string, error) {
 	return reader.ReadAll()
 }
 
-func generateTraceID(random io.Reader) data.TraceID {
+func generatePDataTraceID(random io.Reader) pdata.TraceID {
 	var r [16]byte
 	_, err := random.Read(r[:])
 	if err != nil {
 		panic(err)
 	}
-	return data.NewTraceID(r)
+	return pdata.NewTraceID(r)
 }
 
-func generateSpanID(random io.Reader) data.SpanID {
+func generatePDataSpanID(random io.Reader) pdata.SpanID {
 	var r [8]byte
 	_, err := random.Read(r[:])
 	if err != nil {
 		panic(err)
 	}
-	return data.NewSpanID(r)
+	return pdata.NewSpanID(r)
 }

internal/goldendataset/resource_generator.go

@@ -15,6 +15,7 @@
 package goldendataset
 
 import (
+	"go.opentelemetry.io/collector/consumer/pdata"
 	otlpcommon "go.opentelemetry.io/collector/internal/data/protogen/common/v1"
 	otlpresource "go.opentelemetry.io/collector/internal/data/protogen/resource/v1"
 	"go.opentelemetry.io/collector/translator/conventions"
@@ -56,6 +57,36 @@ func GenerateResource(rscID PICTInputResource) otlpresource.Resource {
 	}
 }
 
+// generatePDataResource generates a PData Resource object with representative attributes for the
+// underlying resource type specified by the rscID input parameter.
+func generatePDataResource(rscID PICTInputResource) pdata.Resource {
+	var attrs map[string]interface{}
+	switch rscID {
+	case ResourceNil:
+		attrs = generateNilAttributes()
+	case ResourceEmpty:
+		attrs = generateEmptyAttributes()
+	case ResourceVMOnPrem:
+		attrs = generateOnpremVMAttributes()
+	case ResourceVMCloud:
+		attrs = generateCloudVMAttributes()
+	case ResourceK8sOnPrem:
+		attrs = generateOnpremK8sAttributes()
+	case ResourceK8sCloud:
+		attrs = generateCloudK8sAttributes()
+	case ResourceFaas:
+		attrs = generateFassAttributes()
+	case ResourceExec:
+		attrs = generateExecAttributes()
+	default:
+		attrs = generateEmptyAttributes()
+	}
+	resource := pdata.NewResource()
+	attrMap := convertMapToAttributeKeyValues(attrs)
+	pdata.NewAttributeMapFromKeyValues(&attrMap).CopyTo(resource.Attributes())
+	return resource
+}
+
 func generateNilAttributes() map[string]interface{} {
 	return nil
 }