Remove last dd dirs (#123)

* Remove dd dirs

* Simplify a couple of test package names

* Remove outdated comment
This commit is contained in:
Trask Stalnaker 2020-02-04 17:43:18 -08:00 committed by GitHub
parent 2248eb4871
commit 8c3ec0cba0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
11 changed files with 16 additions and 24 deletions

View File

@ -1,10 +1,10 @@
import io.opentelemetry.test.instrumentation.springwebflux.server.SpringWebFluxTestApplication
import org.springframework.boot.test.context.SpringBootTest import org.springframework.boot.test.context.SpringBootTest
import org.springframework.boot.test.context.TestConfiguration import org.springframework.boot.test.context.TestConfiguration
import org.springframework.boot.web.embedded.netty.NettyReactiveWebServerFactory import org.springframework.boot.web.embedded.netty.NettyReactiveWebServerFactory
import org.springframework.boot.web.embedded.netty.NettyServerCustomizer import org.springframework.boot.web.embedded.netty.NettyServerCustomizer
import org.springframework.context.annotation.Bean import org.springframework.context.annotation.Bean
import reactor.ipc.netty.resources.LoopResources import reactor.ipc.netty.resources.LoopResources
import server.SpringWebFluxTestApplication
/** /**
* Run all Webflux tests under netty event loop having only 1 thread. * Run all Webflux tests under netty event loop having only 1 thread.

View File

@ -3,10 +3,6 @@ import io.opentelemetry.auto.instrumentation.api.SpanTypes
import io.opentelemetry.auto.instrumentation.api.Tags import io.opentelemetry.auto.instrumentation.api.Tags
import io.opentelemetry.auto.test.AgentTestRunner import io.opentelemetry.auto.test.AgentTestRunner
import io.opentelemetry.auto.test.utils.OkHttpUtils import io.opentelemetry.auto.test.utils.OkHttpUtils
import io.opentelemetry.test.instrumentation.springwebflux.server.EchoHandlerFunction
import io.opentelemetry.test.instrumentation.springwebflux.server.FooModel
import io.opentelemetry.test.instrumentation.springwebflux.server.SpringWebFluxTestApplication
import io.opentelemetry.test.instrumentation.springwebflux.server.TestController
import okhttp3.OkHttpClient import okhttp3.OkHttpClient
import okhttp3.Request import okhttp3.Request
import okhttp3.RequestBody import okhttp3.RequestBody
@ -16,6 +12,10 @@ import org.springframework.boot.web.embedded.netty.NettyReactiveWebServerFactory
import org.springframework.boot.web.server.LocalServerPort import org.springframework.boot.web.server.LocalServerPort
import org.springframework.context.annotation.Bean import org.springframework.context.annotation.Bean
import org.springframework.web.server.ResponseStatusException import org.springframework.web.server.ResponseStatusException
import server.EchoHandlerFunction
import server.FooModel
import server.SpringWebFluxTestApplication
import server.TestController
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = [SpringWebFluxTestApplication, ForceNettyAutoConfiguration]) @SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT, classes = [SpringWebFluxTestApplication, ForceNettyAutoConfiguration])
class SpringWebfluxTest extends AgentTestRunner { class SpringWebfluxTest extends AgentTestRunner {

View File

@ -1,4 +1,4 @@
package io.opentelemetry.test.instrumentation.springwebflux.client package client
import io.opentelemetry.auto.instrumentation.api.MoreTags import io.opentelemetry.auto.instrumentation.api.MoreTags
import io.opentelemetry.auto.instrumentation.api.SpanTypes import io.opentelemetry.auto.instrumentation.api.SpanTypes

View File

@ -1,4 +1,4 @@
package io.opentelemetry.test.instrumentation.springwebflux.server package server
import io.opentelemetry.OpenTelemetry import io.opentelemetry.OpenTelemetry
import io.opentelemetry.trace.Tracer import io.opentelemetry.trace.Tracer
@ -8,10 +8,6 @@ import org.springframework.web.reactive.function.server.ServerRequest
import org.springframework.web.reactive.function.server.ServerResponse import org.springframework.web.reactive.function.server.ServerResponse
import reactor.core.publisher.Mono import reactor.core.publisher.Mono
/**
* Note: this class has to stay outside of 'io.opentelemetry.auto.*' package because we need
* it transformed by {@code @Trace} annotation.
*/
@Component @Component
class EchoHandler { class EchoHandler {

View File

@ -1,4 +1,4 @@
package io.opentelemetry.test.instrumentation.springwebflux.server package server
import org.springframework.web.reactive.function.server.HandlerFunction import org.springframework.web.reactive.function.server.HandlerFunction

View File

@ -1,4 +1,4 @@
package io.opentelemetry.test.instrumentation.springwebflux.server package server
class FooModel { class FooModel {
public long id public long id

View File

@ -1,4 +1,4 @@
package io.opentelemetry.test.instrumentation.springwebflux.server package server
import io.opentelemetry.OpenTelemetry import io.opentelemetry.OpenTelemetry
import io.opentelemetry.trace.Tracer import io.opentelemetry.trace.Tracer

View File

@ -1,4 +1,4 @@
package io.opentelemetry.test.instrumentation.springwebflux.server package server
import io.opentelemetry.OpenTelemetry import io.opentelemetry.OpenTelemetry
import io.opentelemetry.trace.Tracer import io.opentelemetry.trace.Tracer

View File

@ -1,4 +1,4 @@
package io.opentelemetry.test.instrumentation.springwebflux.server; package server;
import static org.springframework.web.reactive.function.server.RequestPredicates.GET; import static org.springframework.web.reactive.function.server.RequestPredicates.GET;
import static org.springframework.web.reactive.function.server.RouterFunctions.route; import static org.springframework.web.reactive.function.server.RouterFunctions.route;

View File

@ -1,10 +1,9 @@
package io.opentelemetry.auto.instrumentation.spymemcached
import com.google.common.util.concurrent.MoreExecutors import com.google.common.util.concurrent.MoreExecutors
import io.opentelemetry.auto.config.Config import io.opentelemetry.auto.config.Config
import io.opentelemetry.auto.instrumentation.api.MoreTags import io.opentelemetry.auto.instrumentation.api.MoreTags
import io.opentelemetry.auto.instrumentation.api.SpanTypes import io.opentelemetry.auto.instrumentation.api.SpanTypes
import io.opentelemetry.auto.instrumentation.api.Tags import io.opentelemetry.auto.instrumentation.api.Tags
import io.opentelemetry.auto.instrumentation.spymemcached.CompletionListener
import io.opentelemetry.auto.test.AgentTestRunner import io.opentelemetry.auto.test.AgentTestRunner
import io.opentelemetry.auto.test.asserts.TraceAssert import io.opentelemetry.auto.test.asserts.TraceAssert
import net.spy.memcached.CASResponse import net.spy.memcached.CASResponse
@ -25,9 +24,6 @@ import java.util.concurrent.BlockingQueue
import java.util.concurrent.ExecutorService import java.util.concurrent.ExecutorService
import java.util.concurrent.locks.ReentrantLock import java.util.concurrent.locks.ReentrantLock
import static CompletionListener.COMPONENT_NAME
import static CompletionListener.OPERATION_NAME
import static CompletionListener.SERVICE_NAME
import static io.opentelemetry.auto.test.utils.TraceUtils.runUnderTrace import static io.opentelemetry.auto.test.utils.TraceUtils.runUnderTrace
import static net.spy.memcached.ConnectionFactoryBuilder.Protocol.BINARY import static net.spy.memcached.ConnectionFactoryBuilder.Protocol.BINARY
@ -630,14 +626,14 @@ class SpymemcachedTest extends AgentTestRunner {
childOf(trace.span(0)) childOf(trace.span(0))
} }
operationName OPERATION_NAME operationName CompletionListener.OPERATION_NAME
errored(error != null && error != "canceled") errored(error != null && error != "canceled")
tags { tags {
"$MoreTags.SERVICE_NAME" SERVICE_NAME "$MoreTags.SERVICE_NAME" CompletionListener.SERVICE_NAME
"$MoreTags.RESOURCE_NAME" operation "$MoreTags.RESOURCE_NAME" operation
"$MoreTags.SPAN_TYPE" SpanTypes.MEMCACHED "$MoreTags.SPAN_TYPE" SpanTypes.MEMCACHED
"$Tags.COMPONENT" COMPONENT_NAME "$Tags.COMPONENT" CompletionListener.COMPONENT_NAME
"$Tags.SPAN_KIND" Tags.SPAN_KIND_CLIENT "$Tags.SPAN_KIND" Tags.SPAN_KIND_CLIENT
"$Tags.DB_TYPE" CompletionListener.DB_TYPE "$Tags.DB_TYPE" CompletionListener.DB_TYPE