single out OpentelemetryTestSuite

Signed-off-by: TJ Zhang <[email protected]>

Author: tjzhang-BQ

.github/workflows/go.yml

@@ -372,3 +372,64 @@ jobs:
                       utils/clusters/**
                       benchmarks/results/**
                       go/reports/**
+
+    test-opentelemetry:
+        name: Go OpenTelemetry Tests - ${{ matrix.go }}, EngineVersion - ${{ matrix.engine.version }}, Target - ${{ matrix.host.TARGET }}
+        needs: get-matrices
+        timeout-minutes: 35
+        strategy:
+            fail-fast: false
+            matrix:
+                go: ${{ fromJson(needs.get-matrices.outputs.version-matrix-output) }}
+                engine: ${{ fromJson(needs.get-matrices.outputs.engine-matrix-output) }}
+                host: ${{ fromJson(needs.get-matrices.outputs.host-matrix-output) }}
+        runs-on: ${{ matrix.host.RUNNER }}
+
+        steps:
+            - uses: actions/checkout@v4
+
+            - name: Output Matrix Parameters for this job
+              run: |
+                  echo "Job running with the following matrix configuration:"
+                  echo "${{ toJson(matrix) }}"
+
+            - name: Set up Go ${{ matrix.go }}
+              uses: actions/setup-go@v5
+              with:
+                  go-version: ${{ matrix.go }}
+                  cache-dependency-path: go/go.sum
+
+            - name: Install shared software dependencies
+              uses: ./.github/workflows/install-shared-dependencies
+              with:
+                  os: ${{ matrix.host.OS }}
+                  target: ${{ matrix.host.TARGET }}
+                  github-token: ${{ secrets.GITHUB_TOKEN }}
+                  engine-version: ${{ matrix.engine.version }}
+
+            - uses: actions/cache@v4
+              with:
+                  path: |
+                      ffi/target
+                      glide-core/src/generated
+                  key: ${{ matrix.host.TARGET }}-go
+                  restore-keys: |
+                      ${{ matrix.host.TARGET }}-glide-core
+                      ${{ matrix.host.TARGET }}
+
+            - name: Install & build & test
+              working-directory: go
+              run: |
+                  make install-tools build
+                  make -k opentelemetry-test test-filter=TestOpenTelemetry
+
+            - name: Upload logs and reports
+              if: always()
+              continue-on-error: true
+              uses: actions/upload-artifact@v4
+              with:
+                  name: test-report-go-opentelemetry-${{ matrix.go }}-${{ matrix.engine.type }}-${{ matrix.engine.version }}-${{ matrix.host.RUNNER }}
+                  path: |
+                      utils/clusters/**
+                      benchmarks/results/**
+                      go/reports/**

go/Makefile

@@ -152,7 +152,7 @@ example-test:
 	| go-test-report -o reports/example-tests.html -t example-test > /dev/null)
 
 # integration tests - run subtask with skipping modules tests
-integ-test: export TEST_FILTER = -skip TestGlideTestSuite/TestModule $(if $(test-filter), -testify.m $(test-filter))
+integ-test: export TEST_FILTER = -skip TestGlideTestSuite/TestModule -skip TestOpenTelemetryTestSuite $(if $(test-filter), -testify.m $(test-filter))
 integ-test: __it
 
 # modules tests - run substask with default filter
@@ -167,6 +167,10 @@ pubsub-test: __it
 long-timeout-test: export TEST_FILTER = -skip TestGlideTestSuite/TestModule -long-timeout-tests $(if $(test-filter), -testify.m $(test-filter))
 long-timeout-test: __it
 
+# opentelemetry tests - run subtask with the opentelemetry flag enabled
+opentelemetry-test: export TEST_FILTER = -skip TestGlideTestSuite/TestModule -otel-test $(if $(test-filter), -testify.m $(test-filter))
+opentelemetry-test: __it
+
 __it:
 	mkdir -p reports
 	set -o pipefail; \

go/integTest/glide_test_suite_test.go

@@ -60,6 +60,7 @@ var (
 	)
 	pubsubtest       = flag.Bool("pubsub", false, "Set to true to run pubsub tests")
 	longTimeoutTests = flag.Bool("long-timeout-tests", false, "Set to true to run tests with longer timeouts")
+	otelTest         = flag.Bool("otel-test", false, "Set to true to run opentelemetry tests")
 )
 
 func (suite *GlideTestSuite) SetupSuite() {

go/integTest/opentelemetry_test.go

@@ -188,6 +188,9 @@ func readAndParseSpanFile(path string) (SpanFileData, error) {
 }
 
 func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_AutomaticSpanLifecycle() {
+	if !*otelTest {
+		suite.T().Skip("OpenTelemetry tests are disabled")
+	}
 	suite.runWithSpecificClients(ClientTypeFlag(StandaloneFlag), func(client interfaces.BaseClientCommands) {
 		// Force garbage collection
 		runtime.GC()
@@ -216,6 +219,9 @@ func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_AutomaticSpanLifecycle()
 }
 
 func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_GlobalConfigNotReinitialize() {
+	if !*otelTest {
+		suite.T().Skip("OpenTelemetry tests are disabled")
+	}
 	suite.runWithSpecificClients(ClientTypeFlag(StandaloneFlag), func(client interfaces.BaseClientCommands) {
 		// Try to initialize OpenTelemetry with wrong endpoint
 		wrongConfig := glide.OpenTelemetryConfig{
@@ -244,6 +250,9 @@ func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_GlobalConfigNotReinitiali
 }
 
 func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ConcurrentCommandsSpanLifecycle() {
+	if !*otelTest {
+		suite.T().Skip("OpenTelemetry tests are disabled")
+	}
 	suite.runWithSpecificClients(ClientTypeFlag(StandaloneFlag), func(client interfaces.BaseClientCommands) {
 		// Force garbage collection
 		runtime.GC()
@@ -304,6 +313,9 @@ func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ConcurrentCommandsSpanLif
 
 // cluster tests
 func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ClusterClientMemoryLeak() {
+	if !*otelTest {
+		suite.T().Skip("OpenTelemetry tests are disabled")
+	}
 	suite.runWithSpecificClients(ClientTypeFlag(ClusterFlag), func(client interfaces.BaseClientCommands) {
 		// Force garbage collection
 		runtime.GC()
@@ -336,6 +348,9 @@ func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ClusterClientMemoryLeak()
 }
 
 func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ClusterClientSamplingPercentage() {
+	if !*otelTest {
+		suite.T().Skip("OpenTelemetry tests are disabled")
+	}
 	suite.runWithSpecificClients(ClientTypeFlag(ClusterFlag), func(client interfaces.BaseClientCommands) {
 		// Set sampling percentage to 0
 		err := glide.GetInstance().SetSamplePercentage(0)
@@ -396,6 +411,9 @@ func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ClusterClientSamplingPerc
 }
 
 func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ClusterClientGlobalConfigNotReinitialize() {
+	if !*otelTest {
+		suite.T().Skip("OpenTelemetry tests are disabled")
+	}
 	suite.runWithSpecificClients(ClientTypeFlag(ClusterFlag), func(client interfaces.BaseClientCommands) {
 		// Try to initialize OpenTelemetry with wrong endpoint
 		wrongConfig := glide.OpenTelemetryConfig{
@@ -424,6 +442,9 @@ func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ClusterClientGlobalConfig
 }
 
 func (suite *OpenTelemetryTestSuite) TestOpenTelemetry_ClusterClientMultipleClients() {
+	if !*otelTest {
+		suite.T().Skip("OpenTelemetry tests are disabled")
+	}
 	suite.runWithSpecificClients(ClientTypeFlag(ClusterFlag), func(client1 interfaces.BaseClientCommands) {
 		// Create a second client with the same configuration
 		client2 := suite.clusterClient(suite.defaultClusterClientConfig())