unit tests

Author: fandreuz

sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/SdkMeterProviderTest.java

@@ -28,8 +28,10 @@
 import io.opentelemetry.context.Scope;
 import io.opentelemetry.sdk.common.CompletableResultCode;
 import io.opentelemetry.sdk.common.InstrumentationScopeInfo;
+import io.opentelemetry.sdk.internal.ScopeConfigurator;
 import io.opentelemetry.sdk.metrics.data.MetricData;
 import io.opentelemetry.sdk.metrics.export.MetricReader;
+import io.opentelemetry.sdk.metrics.internal.MeterConfig;
 import io.opentelemetry.sdk.metrics.internal.SdkMeterProviderUtil;
 import io.opentelemetry.sdk.metrics.internal.view.ViewRegistry;
 import io.opentelemetry.sdk.resources.Resource;
@@ -47,6 +49,7 @@
 import java.util.concurrent.TimeoutException;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Consumer;
+import org.assertj.core.api.Assertions;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.junit.jupiter.api.extension.RegisterExtension;
@@ -1030,6 +1033,34 @@ void resetForTest() {
                         sum -> sum.isCumulative().hasPointsSatisfying(point -> point.hasValue(1))));
   }
 
+  private static ScopeConfigurator<MeterConfig> flipConfigurator(boolean enabled) {
+    return scopeInfo -> enabled ? MeterConfig.disabled() : MeterConfig.enabled();
+  }
+
+  @Test
+  void propagatesEnablementToLoggerDirectly() {
+    SdkMeterProvider meterProvider =
+        SdkMeterProvider.builder().registerMetricReader(InMemoryMetricReader.create()).build();
+    SdkMeter meter = (SdkMeter) meterProvider.get("test");
+    boolean isEnabled = meter.isMeterEnabled();
+
+    meterProvider.setMeterConfigurator(flipConfigurator(isEnabled));
+
+    Assertions.assertThat(meter.isMeterEnabled()).isEqualTo(!isEnabled);
+  }
+
+  @Test
+  void propagatesEnablementToLoggerByUtil() {
+    SdkMeterProvider sdkMeterProvider =
+        SdkMeterProvider.builder().registerMetricReader(InMemoryMetricReader.create()).build();
+    SdkMeter sdkMeter = (SdkMeter) sdkMeterProvider.get("test");
+    boolean isEnabled = sdkMeter.isMeterEnabled();
+
+    SdkMeterProviderUtil.setMeterConfigurator(sdkMeterProvider, flipConfigurator(isEnabled));
+
+    Assertions.assertThat(sdkMeter.isMeterEnabled()).isEqualTo(!isEnabled);
+  }
+
   private static void registerViewForAllTypes(
       SdkMeterProviderBuilder meterProviderBuilder, Aggregation aggregation) {
     for (InstrumentType instrumentType : InstrumentType.values()) {

sdk/metrics/src/test/java/io/opentelemetry/sdk/metrics/SdkMeterTest.java

@@ -18,6 +18,7 @@
 import io.opentelemetry.api.metrics.Meter;
 import io.opentelemetry.api.metrics.MeterProvider;
 import io.opentelemetry.internal.testing.slf4j.SuppressLogger;
+import io.opentelemetry.sdk.metrics.internal.MeterConfig;
 import io.opentelemetry.sdk.metrics.internal.state.MetricStorageRegistry;
 import io.opentelemetry.sdk.testing.exporter.InMemoryMetricReader;
 import java.util.Locale;
@@ -481,4 +482,16 @@ void stringRepresentation() {
                 + "attributes={}"
                 + "}}");
   }
+
+  @Test
+  void updateEnabled() {
+    SdkMeterProvider sdkMeterProvider =
+        SdkMeterProvider.builder().registerMetricReader(InMemoryMetricReader.create()).build();
+    SdkMeter meter = (SdkMeter) sdkMeterProvider.get("test");
+
+    meter.updateMeterConfig(MeterConfig.disabled());
+    assertThat(meter.isMeterEnabled()).isFalse();
+    meter.updateMeterConfig(MeterConfig.enabled());
+    assertThat(meter.isMeterEnabled()).isTrue();
+  }
 }