use glibc based image

Author: jinja2

Makefile

@@ -328,13 +328,17 @@ kind-delete: ## Delete kind cluster and remove kubeconfig
 	@echo "=== Kind cluster cleanup complete ==="
 
 PYTHON_TEST_IMAGE ?= quay.io/splunko11ytest/python_test:latest
+NODEJS_TEST_IMAGE ?= quay.io/splunko11ytest/nodejs_test:latest
 
 .PHONY: kind-build-test-images
 kind-build-test-images: ## Build test app images and load them into kind cluster
 	@echo "Building Python test app image..."
 	docker build -t $(PYTHON_TEST_IMAGE) functional_tests/functional/testdata/python
-	@echo "Loading Python test app image into kind cluster..."
+	@echo "Building Node.js test app image..."
+	docker build -t $(NODEJS_TEST_IMAGE) functional_tests/functional/testdata/nodejs
+	@echo "Loading test app images into kind cluster..."
 	kind load docker-image $(PYTHON_TEST_IMAGE) --name=$(KIND_CLUSTER_NAME)
+	kind load docker-image $(NODEJS_TEST_IMAGE) --name=$(KIND_CLUSTER_NAME)
 	@echo "=== Test images loaded into kind ==="
 
 .PHONY: functionaltest-local

functional_tests/functional/auto_instrumentation_test.go

@@ -58,7 +58,7 @@ func testNodeJSTraces(t *testing.T) {
 	var selectedTrace *ptrace.Traces
 
 	require.Eventually(t, func() bool {
-		for i := len(tracesConsumer.AllTraces()) - 1; i > 0; i-- {
+		for i := len(tracesConsumer.AllTraces()) - 1; i >= 0; i-- {
 			trace := tracesConsumer.AllTraces()[i]
 			if val, ok := trace.ResourceSpans().At(0).Resource().Attributes().Get("telemetry.sdk.language"); ok && strings.Contains(val.Str(), "nodejs") {
 				if expectedTraces.SpanCount() == trace.SpanCount() && expectedTraces.ResourceSpans().Len() == trace.ResourceSpans().Len() {
@@ -127,7 +127,7 @@ func testPythonTraces(t *testing.T) {
 
 	read := 0
 	require.Eventually(t, func() bool {
-		for i := len(tracesConsumer.AllTraces()) - 1; i > read; i-- {
+		for i := len(tracesConsumer.AllTraces()) - 1; i >= read; i-- {
 			trace := tracesConsumer.AllTraces()[i]
 			if val, ok := trace.ResourceSpans().At(0).Resource().Attributes().Get("telemetry.sdk.language"); ok && strings.Contains(val.Str(), "python") {
 				if expectedTraces.SpanCount() == trace.SpanCount() && expectedTraces.ResourceSpans().Len() == trace.ResourceSpans().Len() {
@@ -196,7 +196,7 @@ func testJavaTraces(t *testing.T) {
 	var selectedTrace *ptrace.Traces
 
 	require.Eventually(t, func() bool {
-		for i := len(tracesConsumer.AllTraces()) - 1; i > 0; i-- {
+		for i := len(tracesConsumer.AllTraces()) - 1; i >= 0; i-- {
 			trace := tracesConsumer.AllTraces()[i]
 			if val, ok := trace.ResourceSpans().At(0).Resource().Attributes().Get("telemetry.sdk.language"); ok && strings.Contains(val.Str(), "java") {
 				if expectedTraces.SpanCount() == trace.SpanCount() && expectedTraces.ResourceSpans().Len() == trace.ResourceSpans().Len() {
@@ -261,7 +261,7 @@ func testDotNetTraces(t *testing.T) {
 	var selectedTrace *ptrace.Traces
 
 	require.Eventually(t, func() bool {
-		for i := len(tracesConsumer.AllTraces()) - 1; i > 0; i-- {
+		for i := len(tracesConsumer.AllTraces()) - 1; i >= 0; i-- {
 			trace := tracesConsumer.AllTraces()[i]
 			if val, ok := trace.ResourceSpans().At(0).Resource().Attributes().Get("telemetry.sdk.language"); ok && strings.Contains(val.Str(), "dotnet") {
 				if expectedTraces.SpanCount() == trace.SpanCount() && expectedTraces.ResourceSpans().Len() == trace.ResourceSpans().Len() {
@@ -339,8 +339,13 @@ func testPythonMetrics(t *testing.T) {
 	})
 }
 
-// Profiling tests — look for com.splunk.sourcetype=otel.profiling* logs
-// carrying the expected telemetry.sdk.language + service.name.
+// Profiling tests — verify both CPU and memory/allocation profiling logs arrive
+// with com.splunk.sourcetype=otel.profiling for the expected app identity.
+//
+// The HEC exporter identifies profiling data by instrumentation scope name
+// ("otel.profiling"), not by sourcetype. After the HEC round-trip:
+//   - com.splunk.sourcetype, telemetry.sdk.language, service.name → resource attributes
+//   - profiling.data.type (cpu|allocation) → log record attributes
 
 func testJavaProfiling(t *testing.T)   { checkProfilingFromApp(t, "java", "java-test") }
 func testNodeJSProfiling(t *testing.T) { checkProfilingFromApp(t, "nodejs", "nodejs-test") }
@@ -350,34 +355,34 @@ func testPythonProfiling(t *testing.T) { checkProfilingFromApp(t, "python", "pyt
 func checkProfilingFromApp(t *testing.T, sdkLanguage, serviceName string) {
 	lc := globalSinks.logsConsumer
 	label := sdkLanguage + "/" + serviceName
-	require.Eventuallyf(t, func() bool {
-		return hasProfilingFromApp(lc, sdkLanguage, serviceName)
-	}, 3*time.Minute, 5*time.Second,
-		"no profiling logs (otel.profiling*) for %s within timeout", label)
-	t.Logf("Received profiling logs from %s", label)
+	profilingTypes := []string{"cpu", "allocation"}
+	for _, pt := range profilingTypes {
+		t.Run(pt, func(t *testing.T) {
+			require.Eventuallyf(t, func() bool {
+				return hasProfilingFromApp(lc, sdkLanguage, serviceName, pt)
+			}, 3*time.Minute, 5*time.Second,
+				"no %s profiling logs for %s within timeout", pt, label)
+			t.Logf("Received %s profiling logs from %s", pt, label)
+		})
+	}
 }
 
-// hasProfilingFromApp checks the logs sink for profiling entries matching the app.
-// After the HEC round-trip, identity attrs may appear at the resource or log record level.
-func hasProfilingFromApp(lc *consumertest.LogsSink, sdkLanguage, serviceName string) bool {
-	matchIdentity := func(attrs pcommon.Map) bool {
-		return hasAttrMatch(attrs, "telemetry.sdk.language", sdkLanguage) &&
-			hasAttrMatch(attrs, "service.name", serviceName)
-	}
+func hasProfilingFromApp(lc *consumertest.LogsSink, sdkLanguage, serviceName, profilingType string) bool {
 	for _, logs := range lc.AllLogs() {
 		for i := 0; i < logs.ResourceLogs().Len(); i++ {
 			rl := logs.ResourceLogs().At(i)
 			resAttrs := rl.Resource().Attributes()
-			stVal, stOk := resAttrs.Get("com.splunk.sourcetype")
-			if !stOk || !strings.HasPrefix(stVal.Str(), "otel.profiling") {
+			if !hasAttrMatch(resAttrs, "com.splunk.sourcetype", "otel.profiling") {
 				continue
 			}
-			if matchIdentity(resAttrs) {
-				return true
+			if !hasAttrMatch(resAttrs, "telemetry.sdk.language", sdkLanguage) ||
+				!hasAttrMatch(resAttrs, "service.name", serviceName) {
+				continue
 			}
 			for j := 0; j < rl.ScopeLogs().Len(); j++ {
 				for k := 0; k < rl.ScopeLogs().At(j).LogRecords().Len(); k++ {
-					if matchIdentity(rl.ScopeLogs().At(j).LogRecords().At(k).Attributes()) {
+					recAttrs := rl.ScopeLogs().At(j).LogRecords().At(k).Attributes()
+					if hasAttrMatch(recAttrs, "profiling.data.type", profilingType) {
 						return true
 					}
 				}

functional_tests/functional/functional_test.go

@@ -1316,6 +1316,12 @@ func metricDataPointsHaveAttrs(metric pmetric.Metric, kvPairs ...string) bool {
 				return true
 			}
 		}
+	case pmetric.MetricTypeExponentialHistogram:
+		for i := 0; i < metric.ExponentialHistogram().DataPoints().Len(); i++ {
+			if check(metric.ExponentialHistogram().DataPoints().At(i).Attributes()) {
+				return true
+			}
+		}
 	}
 	return false
 }

functional_tests/functional/testdata/nodejs/Dockerfile

@@ -1,6 +1,6 @@
-FROM node:18-alpine
+FROM node:18-slim
 
-RUN apk add --no-cache bash curl
+RUN apt-get update && apt-get install -y --no-install-recommends bash curl && rm -rf /var/lib/apt/lists/*
 
 COPY index.js start.sh /
 

functional_tests/functional/testdata/nodejs/deployment.yaml

@@ -20,12 +20,5 @@ spec:
         - image: quay.io/splunko11ytest/nodejs_test:latest
           name: nodejs-test
           imagePullPolicy: IfNotPresent
-          env:
-            - name: NODE_IP
-              valueFrom:
-                fieldRef:
-                  fieldPath: status.hostIP
-            - name: SPLUNK_PROFILER_LOGS_ENDPOINT
-              value: "http://$(NODE_IP):4318"
       nodeSelector:
         kubernetes.io/os: "linux"