Verify parsed content in the test

open-telemetry · Oct 12, 2021 · a9d0f07 · a9d0f07
1 parent 875cb94
commit a9d0f07
Showing 1 changed file with 118 additions and 0 deletions.
diff --git a/schema/v1.0/parser_test.go b/schema/v1.0/parser_test.go
@@ -19,12 +19,130 @@ import (
 	"testing"
 
 	"github.com/stretchr/testify/assert"
+	"go.opentelemetry.io/otel/schema/v1.0/ast"
+	"go.opentelemetry.io/otel/schema/v1.0/types"
 )
 
 func TestParseSchemaFile(t *testing.T) {
 	ts, err := ParseFile("testdata/valid-example.yaml")
 	assert.NoError(t, err)
 	assert.NotNil(t, ts)
+	assert.EqualValues(t, &ast.Schema{
+		FileFormat: "1.0.0",
+		SchemaURL:  "https://opentelemetry.io/schemas/1.1.0",
+		Versions: map[types.TelemetryVersion]ast.VersionDef{
+			"1.0.0": {},
+
+			"1.1.0": {
+				All: ast.Attributes{
+					Changes: []ast.AttributeChange{
+						{RenameAttributes: &ast.AttributeMap{
+							"k8s.cluster.name":     "kubernetes.cluster.name",
+							"k8s.namespace.name":   "kubernetes.namespace.name",
+							"k8s.node.name":        "kubernetes.node.name",
+							"k8s.node.uid":         "kubernetes.node.uid",
+							"k8s.pod.name":         "kubernetes.pod.name",
+							"k8s.pod.uid":          "kubernetes.pod.uid",
+							"k8s.container.name":   "kubernetes.container.name",
+							"k8s.replicaset.name":  "kubernetes.replicaset.name",
+							"k8s.replicaset.uid":   "kubernetes.replicaset.uid",
+							"k8s.cronjob.name":     "kubernetes.cronjob.name",
+							"k8s.cronjob.uid":      "kubernetes.cronjob.uid",
+							"k8s.job.name":         "kubernetes.job.name",
+							"k8s.job.uid":          "kubernetes.job.uid",
+							"k8s.statefulset.name": "kubernetes.statefulset.name",
+							"k8s.statefulset.uid":  "kubernetes.statefulset.uid",
+							"k8s.daemonset.name":   "kubernetes.daemonset.name",
+							"k8s.daemonset.uid":    "kubernetes.daemonset.uid",
+							"k8s.deployment.name":  "kubernetes.deployment.name",
+							"k8s.deployment.uid":   "kubernetes.deployment.uid",
+							"service.namespace":    "service.namespace.name",
+						}},
+					},
+				},
+
+				Resources: ast.Attributes{
+					Changes: []ast.AttributeChange{
+						{
+							RenameAttributes: &ast.AttributeMap{
+								"telemetry.auto.version": "telemetry.auto_instr.version",
+							},
+						},
+					},
+				},
+
+				Spans: ast.Spans{
+					Changes: []ast.SpansChange{
+						{
+							RenameAttributes: &ast.RenameAttributes{
+								AttributeMap: ast.AttributeMap{
+									"peer.service": "peer.service.name",
+								},
+							},
+						},
+					},
+				},
+
+				SpanEvents: ast.SpanEvents{
+					Changes: []ast.SpanEventsChange{
+						{
+							RenameEvents: &ast.RenameSpanEvents{
+								EventNameMap: map[string]string{
+									"exception.stacktrace": "exception.stack_trace",
+								},
+							},
+						},
+						{
+							RenameAttributes: &ast.RenameSpanEventAttributes{
+								ApplyToEvents: []types.EventName{"exception.stack_trace"},
+								AttributeMap: ast.AttributeMap{
+									"peer.service": "peer.service.name",
+								},
+							},
+						},
+					},
+				},
+
+				Logs: ast.Logs{Changes: []ast.LogsChange{
+					{RenameAttributes: &ast.RenameAttributes{
+						AttributeMap: map[string]string{
+							"process.executable_name": "process.executable.name",
+						},
+					}},
+				}},
+
+				Metrics: ast.Metrics{
+					Changes: []ast.MetricsChange{
+						{
+							RenameAttributes: &ast.AttributeMapForMetrics{
+								AttributeMap: map[string]string{
+									"http.status_code": "http.response_status_code",
+								},
+							}},
+						{
+							RenameMetrics: map[types.MetricName]types.MetricName{
+								"container.cpu.usage.total":  "cpu.usage.total",
+								"container.memory.usage.max": "memory.usage.max",
+							},
+						},
+						{
+							RenameAttributes: &ast.AttributeMapForMetrics{
+								ApplyToMetrics: []types.MetricName{
+									"system.cpu.utilization",
+									"system.memory.usage",
+									"system.memory.utilization",
+									"system.paging.usage",
+								},
+								AttributeMap: map[string]string{
+									"status": "state",
+								},
+							},
+						},
+					},
+				},
+			},
+		},
+	}, ts)
 }
 
 func TestFailParseSchemaFile(t *testing.T) {