Commit 33d65184 by Jon Schneider

Deconflict GaugeService provided by Servo/Spectator integration

parent 2bb6befb
...@@ -27,7 +27,6 @@ import org.springframework.context.annotation.Import; ...@@ -27,7 +27,6 @@ import org.springframework.context.annotation.Import;
import org.springframework.web.client.RestTemplate; import org.springframework.web.client.RestTemplate;
import com.netflix.servo.MonitorRegistry; import com.netflix.servo.MonitorRegistry;
import com.netflix.servo.publish.MetricPoller;
import com.netflix.servo.publish.MonitorRegistryMetricPoller; import com.netflix.servo.publish.MonitorRegistryMetricPoller;
import com.netflix.servo.tag.BasicTagList; import com.netflix.servo.tag.BasicTagList;
...@@ -65,13 +64,7 @@ public class AtlasAutoConfiguration { ...@@ -65,13 +64,7 @@ public class AtlasAutoConfiguration {
@Bean @Bean
@ConditionalOnMissingBean @ConditionalOnMissingBean
public MetricPoller metricPoller(MonitorRegistry monitorRegistry) { public Exporter exporter(AtlasMetricObserver observer, MonitorRegistry monitorRegistry) {
return new MonitorRegistryMetricPoller(monitorRegistry); return new AtlasExporter(observer, new MonitorRegistryMetricPoller(monitorRegistry));
}
@Bean
@ConditionalOnMissingBean
public Exporter exporter(AtlasMetricObserver observer, MetricPoller poller) {
return new AtlasExporter(observer, poller);
} }
} }
...@@ -81,12 +81,12 @@ public class AtlasMetricObserver implements MetricObserver { ...@@ -81,12 +81,12 @@ public class AtlasMetricObserver implements MetricObserver {
protected static boolean validTags(TagList tags) { protected static boolean validTags(TagList tags) {
for (Tag tag : tags) { for (Tag tag : tags) {
if (!validAtlasTag.matcher(tag.getKey()).matches()) { if (!validAtlasTag.matcher(tag.getKey()).matches()) {
logger.error("Invalid tag key " + tag.getKey()); logger.debug("Invalid tag key " + tag.getKey());
return false; return false;
} }
if (!validAtlasTag.matcher(tag.getValue()).matches()) { if (!validAtlasTag.matcher(tag.getValue()).matches()) {
logger.error("Invalid tag value " + tag.getValue()); logger.debug("Invalid tag value " + tag.getValue());
return false; return false;
} }
} }
......
...@@ -13,10 +13,8 @@ ...@@ -13,10 +13,8 @@
package org.springframework.cloud.netflix.metrics.servo; package org.springframework.cloud.netflix.metrics.servo;
import org.springframework.boot.actuate.autoconfigure.EndpointAutoConfiguration; import org.springframework.boot.actuate.autoconfigure.MetricRepositoryAutoConfiguration;
import org.springframework.boot.actuate.endpoint.MetricReaderPublicMetrics; import org.springframework.boot.actuate.endpoint.MetricReaderPublicMetrics;
import org.springframework.boot.actuate.metrics.CounterService;
import org.springframework.boot.actuate.metrics.GaugeService;
import org.springframework.boot.actuate.metrics.reader.MetricReader; import org.springframework.boot.actuate.metrics.reader.MetricReader;
import org.springframework.boot.autoconfigure.AutoConfigureBefore; import org.springframework.boot.autoconfigure.AutoConfigureBefore;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass; import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
...@@ -43,7 +41,7 @@ import com.netflix.servo.monitor.Monitors; ...@@ -43,7 +41,7 @@ import com.netflix.servo.monitor.Monitors;
@Configuration @Configuration
@ConditionalOnClass({ Monitors.class, MetricReader.class }) @ConditionalOnClass({ Monitors.class, MetricReader.class })
@ConditionalOnMissingClass("com.netflix.spectator.api.Registry") @ConditionalOnMissingClass("com.netflix.spectator.api.Registry")
@AutoConfigureBefore(EndpointAutoConfiguration.class) @AutoConfigureBefore(MetricRepositoryAutoConfiguration.class)
@Import(MetricsInterceptorConfiguration.class) @Import(MetricsInterceptorConfiguration.class)
public class ServoMetricsAutoConfiguration { public class ServoMetricsAutoConfiguration {
@Bean @Bean
...@@ -78,8 +76,7 @@ public class ServoMetricsAutoConfiguration { ...@@ -78,8 +76,7 @@ public class ServoMetricsAutoConfiguration {
} }
@Bean @Bean
@ConditionalOnMissingBean({ ServoMetricServices.class, CounterService.class, GaugeService.class }) public ServoMetricServices servoMetricServices(MonitorRegistry monitorRegistry) {
public ServoMetricServices spectatorMetricServices(MonitorRegistry monitorRegistry) {
return new ServoMetricServices(monitorRegistry); return new ServoMetricServices(monitorRegistry);
} }
......
...@@ -14,7 +14,7 @@ ...@@ -14,7 +14,7 @@
package org.springframework.cloud.netflix.metrics.spectator; package org.springframework.cloud.netflix.metrics.spectator;
import org.springframework.beans.factory.annotation.Value; import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.actuate.autoconfigure.EndpointAutoConfiguration; import org.springframework.boot.actuate.autoconfigure.MetricRepositoryAutoConfiguration;
import org.springframework.boot.actuate.endpoint.MetricReaderPublicMetrics; import org.springframework.boot.actuate.endpoint.MetricReaderPublicMetrics;
import org.springframework.boot.actuate.metrics.reader.MetricReader; import org.springframework.boot.actuate.metrics.reader.MetricReader;
import org.springframework.boot.autoconfigure.AutoConfigureBefore; import org.springframework.boot.autoconfigure.AutoConfigureBefore;
...@@ -30,8 +30,6 @@ import org.springframework.context.annotation.Import; ...@@ -30,8 +30,6 @@ import org.springframework.context.annotation.Import;
import com.netflix.servo.DefaultMonitorRegistry; import com.netflix.servo.DefaultMonitorRegistry;
import com.netflix.servo.MonitorRegistry; import com.netflix.servo.MonitorRegistry;
import com.netflix.servo.publish.MetricPoller;
import com.netflix.servo.publish.MonitorRegistryMetricPoller;
import com.netflix.spectator.api.Registry; import com.netflix.spectator.api.Registry;
import com.netflix.spectator.servo.ServoRegistry; import com.netflix.spectator.servo.ServoRegistry;
...@@ -46,7 +44,7 @@ import com.netflix.spectator.servo.ServoRegistry; ...@@ -46,7 +44,7 @@ import com.netflix.spectator.servo.ServoRegistry;
* @author Jon Schneider * @author Jon Schneider
*/ */
@Configuration @Configuration
@AutoConfigureBefore(EndpointAutoConfiguration.class) @AutoConfigureBefore(MetricRepositoryAutoConfiguration.class)
@ConditionalOnClass({ Registry.class, MetricReader.class }) @ConditionalOnClass({ Registry.class, MetricReader.class })
@Import(MetricsInterceptorConfiguration.class) @Import(MetricsInterceptorConfiguration.class)
public class SpectatorMetricsAutoConfiguration { public class SpectatorMetricsAutoConfiguration {
...@@ -73,7 +71,6 @@ public class SpectatorMetricsAutoConfiguration { ...@@ -73,7 +71,6 @@ public class SpectatorMetricsAutoConfiguration {
} }
@Bean @Bean
@ConditionalOnMissingBean
public SpectatorMetricServices spectatorMetricServices(Registry metricRegistry) { public SpectatorMetricServices spectatorMetricServices(Registry metricRegistry) {
return new SpectatorMetricServices(metricRegistry); return new SpectatorMetricServices(metricRegistry);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment