1- import datadog.communication.ddagent.DDAgentFeaturesDiscovery
1+ import static datadog.communication.ddagent.DDAgentFeaturesDiscovery.V06_METRICS_ENDPOINT
2+ import static datadog.trace.common.metrics.EventListener.EventType.OK
3+ import static java.util.concurrent.TimeUnit.SECONDS
4+
25import datadog.communication.http.OkHttpUtils
36import datadog.metrics.api.Histograms
47import datadog.metrics.impl.DDSketchHistograms
@@ -10,14 +13,10 @@ import datadog.trace.common.metrics.EventListener
1013import datadog.trace.common.metrics.MetricKey
1114import datadog.trace.common.metrics.OkHttpSink
1215import datadog.trace.common.metrics.SerializingMetricWriter
13- import okhttp3.HttpUrl
14-
1516import java.util.concurrent.CopyOnWriteArrayList
1617import java.util.concurrent.CountDownLatch
1718import java.util.concurrent.atomic.AtomicLongArray
18-
19- import static datadog.trace.common.metrics.EventListener.EventType.OK
20- import static java.util.concurrent.TimeUnit.SECONDS
19+ import okhttp3.HttpUrl
2120
2221class MetricsIntegrationTest extends AbstractTraceAgentTest {
2322
@@ -31,7 +30,7 @@ class MetricsIntegrationTest extends AbstractTraceAgentTest {
3130 def latch = new CountDownLatch (1 )
3231 def listener = new BlockingListener (latch)
3332 def agentUrl = Config . get(). getAgentUrl()
34- OkHttpSink sink = new OkHttpSink (OkHttpUtils . buildHttpClient(HttpUrl . parse(agentUrl), 5000L ), agentUrl, DDAgentFeaturesDiscovery . V6_METRICS_ENDPOINT , true , false , [:])
33+ OkHttpSink sink = new OkHttpSink (OkHttpUtils . buildHttpClient(HttpUrl . parse(agentUrl), 5000L ), agentUrl, V06_METRICS_ENDPOINT , true , false , [:])
3534 sink. register(listener)
3635
3736 when :
0 commit comments