Skip to content

Commit

Permalink
Remove PushRegistry's numThreads deprecated property
Browse files Browse the repository at this point in the history
  • Loading branch information
snicoll committed Apr 5, 2020
1 parent a23700f commit 7ca6359
Show file tree
Hide file tree
Showing 5 changed files with 96 additions and 35 deletions.
Expand Up @@ -49,11 +49,6 @@ public abstract class PushRegistryProperties {
*/
private Duration readTimeout = Duration.ofSeconds(10);

/**
* Number of threads to use with the metrics publishing scheduler.
*/
private Integer numThreads = 2;

/**
* Number of measurements per request to use for this backend. If more measurements
* are found, then multiple requests will be made.
Expand Down Expand Up @@ -92,16 +87,6 @@ public void setReadTimeout(Duration readTimeout) {
this.readTimeout = readTimeout;
}

@Deprecated
public Integer getNumThreads() {
return this.numThreads;
}

@Deprecated
public void setNumThreads(Integer numThreads) {
this.numThreads = numThreads;
}

public Integer getBatchSize() {
return this.batchSize;
}
Expand Down
Expand Up @@ -56,12 +56,6 @@ public boolean enabled() {
return get(T::isEnabled, PushRegistryConfig.super::enabled);
}

@Override
@SuppressWarnings("deprecation")
public int numThreads() {
return get(T::getNumThreads, PushRegistryConfig.super::numThreads);
}

@Override
public int batchSize() {
return get(T::getBatchSize, PushRegistryConfig.super::batchSize);
Expand Down
Expand Up @@ -220,10 +220,40 @@
"defaultValue": "simple"
},
{
"name": "management.metrics.export.jmx.enabled",
"type": "java.lang.Boolean",
"description": "Whether exporting of metrics to JMX is enabled.",
"defaultValue": true
"name": "management.metrics.export.appoptics.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.datadog.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.dynatrace.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.elastic.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.ganglia.addressing-mode",
Expand All @@ -249,12 +279,45 @@
"name": "management.metrics.export.graphite.rate-units",
"defaultValue": "seconds"
},
{
"name": "management.metrics.export.humio.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.humio.repository",
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.influx.consistency",
"defaultValue": "one"
},
{
"name": "management.metrics.export.humio.repository",
"name": "management.metrics.export.influx.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.jmx.enabled",
"type": "java.lang.Boolean",
"description": "Whether exporting of metrics to JMX is enabled.",
"defaultValue": true
},
{
"name": "management.metrics.export.newrelic.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
Expand All @@ -265,6 +328,15 @@
"description": "Whether exporting of metrics to Prometheus is enabled.",
"defaultValue": true
},
{
"name": "management.metrics.export.signalfx.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.simple.enabled",
"type": "java.lang.Boolean",
Expand All @@ -275,6 +347,15 @@
"name": "management.metrics.export.simple.mode",
"defaultValue": "cumulative"
},
{
"name": "management.metrics.export.stackdriver.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.export.statsd.flavor",
"defaultValue": "datadog"
Expand All @@ -286,6 +367,15 @@
"level": "error"
}
},
{
"name": "management.metrics.export.wavefront.num-threads",
"type": "java.lang.Integer",
"description": "Number of threads to use with the metrics publishing scheduler.",
"defaultValue": 2,
"deprecation": {
"level": "error"
}
},
{
"name": "management.metrics.web.client.request.autotime.enabled",
"description": "Whether to automatically time web client requests.",
Expand Down
Expand Up @@ -50,13 +50,6 @@ void whenPropertiesEnabledIsSetAdapterEnabledReturnsIt() {
assertThat(createConfigAdapter(properties).enabled()).isFalse();
}

@Test
void whenPropertiesNumThreadsIsSetAdapterNumThreadsReturnsIt() {
P properties = createProperties();
properties.setNumThreads(42);
assertThat(createConfigAdapter(properties).numThreads()).isEqualTo(42);
}

@Test
void whenPropertiesBatchSizeIsSetAdapterBatchSizeReturnsIt() {
P properties = createProperties();
Expand Down
@@ -1,5 +1,5 @@
/*
* Copyright 2012-2019 the original author or authors.
* Copyright 2012-2020 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand Down Expand Up @@ -33,7 +33,6 @@ protected void assertStepRegistryDefaultValues(PushRegistryProperties properties
assertThat(properties.isEnabled()).isEqualTo(config.enabled());
assertThat(properties.getConnectTimeout()).isEqualTo(config.connectTimeout());
assertThat(properties.getReadTimeout()).isEqualTo(config.readTimeout());
assertThat(properties.getNumThreads()).isEqualTo(config.numThreads());
assertThat(properties.getBatchSize()).isEqualTo(config.batchSize());
}

Expand Down

0 comments on commit 7ca6359

Please sign in to comment.