From 55811271772e13ba22455c6cb47dde527a78f08e Mon Sep 17 00:00:00 2001 From: Mateusz Rzeszutek Date: Mon, 25 Jul 2022 13:32:00 +0200 Subject: [PATCH] fix rxjava tests --- .../RxJava2WithSpanInstrumentationTest.groovy | 69 +++++++++++++++++++ ...tRxJava3WithSpanInstrumentationTest.groovy | 69 +++++++++++++++++++ 2 files changed, 138 insertions(+) diff --git a/instrumentation/rxjava/rxjava-2.0/javaagent/src/test/groovy/RxJava2WithSpanInstrumentationTest.groovy b/instrumentation/rxjava/rxjava-2.0/javaagent/src/test/groovy/RxJava2WithSpanInstrumentationTest.groovy index 5fccfdeedcb8..3a0e2a310e41 100644 --- a/instrumentation/rxjava/rxjava-2.0/javaagent/src/test/groovy/RxJava2WithSpanInstrumentationTest.groovy +++ b/instrumentation/rxjava/rxjava-2.0/javaagent/src/test/groovy/RxJava2WithSpanInstrumentationTest.groovy @@ -5,6 +5,7 @@ import io.opentelemetry.instrumentation.rxjava.v2_0.TracedWithSpan import io.opentelemetry.instrumentation.test.AgentInstrumentationSpecification +import io.opentelemetry.semconv.trace.attributes.SemanticAttributes import io.reactivex.Completable import io.reactivex.Flowable import io.reactivex.Maybe @@ -43,6 +44,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -72,6 +75,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -98,6 +103,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -130,6 +137,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -158,6 +167,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" "rxjava.canceled" true } } @@ -183,6 +194,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -206,6 +219,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -236,6 +251,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -262,6 +279,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -294,6 +313,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -322,6 +343,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" "rxjava.canceled" true } } @@ -347,6 +370,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -377,6 +402,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -403,6 +430,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -435,6 +464,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -463,6 +494,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" "rxjava.canceled" true } } @@ -488,6 +521,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -523,6 +558,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -549,6 +586,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -587,6 +626,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -621,6 +662,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" "rxjava.canceled" true } } @@ -646,6 +689,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -681,6 +726,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -707,6 +754,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -745,6 +794,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -779,6 +830,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" "rxjava.canceled" true } } @@ -805,6 +858,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -841,6 +896,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -868,6 +925,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -907,6 +966,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -942,6 +1003,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" "rxjava.canceled" true } } @@ -972,6 +1035,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "publisher" } } } @@ -1004,6 +1069,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "publisher" } } } @@ -1032,6 +1099,8 @@ class RxJava2WithSpanInstrumentationTest extends AgentInstrumentationSpecificati kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "publisher" "rxjava.canceled" true } } diff --git a/instrumentation/rxjava/rxjava-3-common/testing/src/main/groovy/io/opentelemetry/instrumentation/rxjava/v3/common/AbstractRxJava3WithSpanInstrumentationTest.groovy b/instrumentation/rxjava/rxjava-3-common/testing/src/main/groovy/io/opentelemetry/instrumentation/rxjava/v3/common/AbstractRxJava3WithSpanInstrumentationTest.groovy index 6bf12cc5eb94..3299ffda678b 100644 --- a/instrumentation/rxjava/rxjava-3-common/testing/src/main/groovy/io/opentelemetry/instrumentation/rxjava/v3/common/AbstractRxJava3WithSpanInstrumentationTest.groovy +++ b/instrumentation/rxjava/rxjava-3-common/testing/src/main/groovy/io/opentelemetry/instrumentation/rxjava/v3/common/AbstractRxJava3WithSpanInstrumentationTest.groovy @@ -7,6 +7,7 @@ package io.opentelemetry.instrumentation.rxjava.v3.common import io.opentelemetry.instrumentation.test.AgentInstrumentationSpecification +import io.opentelemetry.semconv.trace.attributes.SemanticAttributes import io.reactivex.rxjava3.core.Completable import io.reactivex.rxjava3.core.Flowable import io.reactivex.rxjava3.core.Maybe @@ -45,6 +46,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -73,6 +76,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -99,6 +104,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -130,6 +137,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" } } } @@ -157,6 +166,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "completable" "rxjava.canceled" true } } @@ -182,6 +193,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -205,6 +218,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -234,6 +249,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -260,6 +277,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -291,6 +310,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" } } } @@ -318,6 +339,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "maybe" "rxjava.canceled" true } } @@ -343,6 +366,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -372,6 +397,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -398,6 +425,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -429,6 +458,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" } } } @@ -456,6 +487,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "single" "rxjava.canceled" true } } @@ -481,6 +514,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -515,6 +550,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -541,6 +578,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -578,6 +617,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" } } } @@ -611,6 +652,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "observable" "rxjava.canceled" true } } @@ -636,6 +679,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -670,6 +715,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -696,6 +743,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -733,6 +782,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" } } } @@ -766,6 +817,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "flowable" "rxjava.canceled" true } } @@ -792,6 +845,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -827,6 +882,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -854,6 +911,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -892,6 +951,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" } } } @@ -926,6 +987,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "parallelFlowable" "rxjava.canceled" true } } @@ -955,6 +1018,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "publisher" } } } @@ -986,6 +1051,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe status ERROR errorEvent(IllegalArgumentException, "Boom") attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "publisher" } } } @@ -1013,6 +1080,8 @@ class AbstractRxJava3WithSpanInstrumentationTest extends AgentInstrumentationSpe kind INTERNAL hasNoParent() attributes { + "$SemanticAttributes.CODE_NAMESPACE" TracedWithSpan.name + "$SemanticAttributes.CODE_FUNCTION" "publisher" "rxjava.canceled" true } }