99import org .slf4j .Logger ;
1010import org .slf4j .LoggerFactory ;
1111
12- public class ConfigInversionMetricCollector
13- implements MetricCollector <ConfigInversionMetricCollector .ConfigInversionMetric > {
14- private static final Logger log = LoggerFactory .getLogger (ConfigInversionMetricCollector .class );
12+ public class ConfigInversionMetricCollectorImpl
13+ implements MetricCollector <ConfigInversionMetricCollectorImpl .ConfigInversionMetric >,
14+ ConfigInversionMetricCollector {
15+ private static final Logger log =
16+ LoggerFactory .getLogger (ConfigInversionMetricCollectorImpl .class );
1517 private static final String CONFIG_INVERSION_KEY_TAG = "config_name:" ;
1618 private static final String CONFIG_INVERSION_METRIC_NAME = "untracked.config.detected" ;
1719 private static final String NAMESPACE = "tracers" ;
18- private static final ConfigInversionMetricCollector INSTANCE =
19- new ConfigInversionMetricCollector ();
20+ private static final ConfigInversionMetricCollectorImpl INSTANCE =
21+ new ConfigInversionMetricCollectorImpl ();
2022
21- private final BlockingQueue <ConfigInversionMetricCollector .ConfigInversionMetric > metricsQueue ;
23+ private final BlockingQueue <ConfigInversionMetricCollectorImpl .ConfigInversionMetric >
24+ metricsQueue ;
2225
23- private ConfigInversionMetricCollector () {
26+ private ConfigInversionMetricCollectorImpl () {
2427 this .metricsQueue = new ArrayBlockingQueue <>(RAW_QUEUE_SIZE );
2528 }
2629
27- public static ConfigInversionMetricCollector getInstance () {
30+ public static ConfigInversionMetricCollectorImpl getInstance () {
2831 return INSTANCE ;
2932 }
3033
@@ -34,7 +37,7 @@ public void setUndocumentedEnvVarMetric(String configName) {
3437
3538 private void setMetricConfigInversionMetric (final String ... tags ) {
3639 if (!metricsQueue .offer (
37- new ConfigInversionMetricCollector .ConfigInversionMetric (
40+ new ConfigInversionMetricCollectorImpl .ConfigInversionMetric (
3841 NAMESPACE , true , CONFIG_INVERSION_METRIC_NAME , "count" , 1 , tags ))) {
3942 log .debug ("Unable to add telemetry metric {} for {}" , CONFIG_INVERSION_METRIC_NAME , tags [0 ]);
4043 }
@@ -46,11 +49,11 @@ public void prepareMetrics() {
4649 }
4750
4851 @ Override
49- public Collection <ConfigInversionMetricCollector .ConfigInversionMetric > drain () {
52+ public Collection <ConfigInversionMetricCollectorImpl .ConfigInversionMetric > drain () {
5053 if (this .metricsQueue .isEmpty ()) {
5154 return Collections .emptyList ();
5255 }
53- List <ConfigInversionMetricCollector .ConfigInversionMetric > drained =
56+ List <ConfigInversionMetricCollectorImpl .ConfigInversionMetric > drained =
5457 new ArrayList <>(this .metricsQueue .size ());
5558 this .metricsQueue .drainTo (drained );
5659 return drained ;
0 commit comments