Fully replace OpenCensus metrics with OpenTelemetry - Core (#1849)

* remove influx-exporter

* update THIRD-PARTY-LICENSES.txt

* refactor metrics model

* introduce OpenTelemetry instruments and replace tags with attributes (wip)

* update THIRD-PARTY-LICENSES.txt

* refactor context propagation (wip)

* update THIRD-PARTY-LICENSES.txt

* update default basic config

* update THIRD-PARTY-LICENSES.txt

* update self monitoring and metric recorders

* update THIRD-PARTY-LICENSES.txt

* update default instrumentation

* fix metric views initialization

* update THIRD-PARTY-LICENSES.txt

* update jmh tests

* check common attributes settings for views

* refactor context propagation

* fix metrics and views deletion

* refactor context propagation

* update THIRD-PARTY-LICENSES.txt

* add OpenTelemetryConfiguredEvent

* refactor common attributes

* update THIRD-PARTY-LICENSES.txt

* add default views

* update THIRD-PARTY-LICENSES.txt

* make tests compile

* update THIRD-PARTY-LICENSES.txt

* fix jmh test

* fix attributes tests

* fix exporter tests

* fix instrumentation tests

* update THIRD-PARTY-LICENSES.txt

* fix configdocsgenerator tests

* remove debug code

* fix configurationserver test

* update THIRD-PARTY-LICENSES.txt

* fix metrics tests

* update THIRD-PARTY-LICENSES.txt

* fix common attributes test

* update THIRD-PARTY-LICENSES.txt

* add metrics tests

* update THIRD-PARTY-LICENSES.txt

* update timewindow test

* update THIRD-PARTY-LICENSES.txt

* remove unsupported character

* update THIRD-PARTY-LICENSES.txt

* remove unused import

* update THIRD-PARTY-LICENSES.txt

* update OpenTelemetryControllerImplIntTest

* update THIRD-PARTY-LICENSES.txt

* update comments

* update THIRD-PARTY-LICENSES.txt

---------

Co-authored-by: github-actions[bot] <github-actions[bot]@users.noreply.github.com>

Author: EddeCCC

THIRD-PARTY-LICENSES.txt

@@ -30,6 +30,7 @@ dependencies {
 
             configServerLibs.comGoogleGuava,
             libs.ioOpentelemetryOpentelemetryApi,
+            libs.ioOpentelemetryOpentelemetrySdkMetrics,
             libs.orgAssertjAssertjCore,
     )
 }

components/inspectit-ocelot-configdocsgenerator/build.gradle

@@ -55,7 +55,7 @@ private String getYaml(String fileName) throws IOException {
      * correctly scopeDoc.
      */
     @BeforeAll
-    private static void createDocObjects() {
+    static void createDocObjects() {
 
         // Create a sample ActionDoc object where there was documentation values in the YAML, i.e. content behind the
         // doc-key
@@ -116,12 +116,12 @@ private static void createDocObjects() {
 
         // Create a sample MetricDoc object
         metricDoc = Mockito.mock(MetricDocs.class);
-        when(metricDoc.getName()).thenReturn("disk/free");
+        when(metricDoc.getName()).thenReturn("disk_free");
         when(metricDoc.getDescription()).thenReturn("free disk space");
         when(metricDoc.getSince()).thenReturn(null);
         when(metricDoc.getUnit()).thenReturn("bytes");
 
-        // Create a sample RuleDoc object to include inside of the other RuleDoc object
+        // Create a sample RuleDoc object to include inside the other RuleDoc object
         // Create the actionCallsMap for the RuleDoc object
         Map<String, Map<String, ActionCallDocs>> actionCallsMapParent = RuleDocsTest.getEmptyActionCallsMap();
         Map<String, ActionCallDocs> actionCallsParent = new HashMap<>();
@@ -162,7 +162,7 @@ private static void createDocObjects() {
         constantTags.put("error", "servicegraph_is_error");
 
         RuleMetricsDocs ruleMetricsDocsMock = Mockito.mock(RuleMetricsDocs.class);
-        when(ruleMetricsDocsMock.getName()).thenReturn("service/in/responsetime");
+        when(ruleMetricsDocsMock.getName()).thenReturn("service_in_responsetime");
         when(ruleMetricsDocsMock.getValue()).thenReturn("servicegraph_duration");
         when(ruleMetricsDocsMock.getDataTags()).thenReturn(dataTags);
         when(ruleMetricsDocsMock.getConstantTags()).thenReturn(constantTags);

components/inspectit-ocelot-configdocsgenerator/src/test/java/inspectit/ocelot/configdocsgenerator/ConfigDocsGeneratorTest.java

@@ -1,13 +1,14 @@
 package inspectit.ocelot.configdocsgenerator.parsing;
 
 import com.google.common.io.Resources;
+import io.opentelemetry.sdk.metrics.InstrumentType;
+import io.opentelemetry.sdk.metrics.InstrumentValueType;
 import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;
 import org.mockito.Mockito;
 import org.mockito.junit.jupiter.MockitoExtension;
 import rocks.inspectit.ocelot.config.model.InspectitConfig;
-import rocks.inspectit.ocelot.config.model.exporters.ExporterEnabledState;
 import rocks.inspectit.ocelot.config.model.instrumentation.actions.GenericActionSettings;
 import rocks.inspectit.ocelot.config.model.instrumentation.documentation.ActionDocumentation;
 import rocks.inspectit.ocelot.config.model.metrics.StandardPollingMetricsRecorderSettings;
@@ -53,13 +54,14 @@ void withPlaceholder() throws IOException {
 
             MetricDefinitionSettings metricDefinitionMock = Mockito.mock(MetricDefinitionSettings.class);
             when(metricDefinitionMock.isEnabled()).thenReturn(true);
-            when(metricDefinitionMock.getType()).thenReturn(MetricDefinitionSettings.MeasureType.LONG);
+            when(metricDefinitionMock.getValueType()).thenReturn(InstrumentValueType.LONG);
+            when(metricDefinitionMock.getInstrumentType()).thenReturn(InstrumentType.GAUGE);
             when(metricDefinitionMock.getUnit()).thenReturn("bytes");
-            when(metricDefinitionMock.getMaxValuesPerTag()).thenReturn(5);
+            when(metricDefinitionMock.getMaxValuesPerAttribute()).thenReturn(5);
             when(metricDefinitionMock.getDescription()).thenReturn("free disk space");
             when(metricDefinitionMock.getViews()).thenReturn(null);
 
-            assertThat(result.getMetrics().getDefinitions().get("disk/free")).usingRecursiveComparison()
+            assertThat(result.getMetrics().getDefinitions().get("disk_free")).usingRecursiveComparison()
                     .isEqualTo(metricDefinitionMock);
           // Build the expected result by hand
             Map<String, Boolean> enabledMap = new HashMap<>();

components/inspectit-ocelot-configdocsgenerator/src/test/java/inspectit/ocelot/configdocsgenerator/parsing/ConfigParserTest.java

@@ -76,7 +76,7 @@ inspectit:
             db.url: jdbc_url
           error-status: _thrown
         metrics:
-          '[service/in/responsetime]':
+          service_in_responsetime:
             value: servicegraph_duration
             data-tags:
               origin_service: servicegraph_origin_service_local
@@ -90,8 +90,7 @@ inspectit:
         # if true, the free disk space will be measured and the view "disk/free" is registered
         free: true
     definitions:
-      '[disk/free]':
+      disk_free:
         enabled: ${inspectit.metrics.disk.enabled.free}
-        type: LONG
         unit: bytes
         description: free disk space

components/inspectit-ocelot-configdocsgenerator/src/test/resources/ConfigDocGeneratorTest/all.yml

@@ -5,8 +5,7 @@ inspectit:
         # if true, the free disk space will be measured and the view "disk/free" is registered
         free: true
     definitions:
-      '[disk/free]':
+      disk_free:
         enabled: ${inspectit.metrics.disk.enabled.free}
-        type: LONG
         unit: bytes
-        description: free disk space
+        description: free disk space

components/inspectit-ocelot-configdocsgenerator/src/test/resources/ConfigDocGeneratorTest/metric.yml

@@ -35,11 +35,11 @@ inspectit:
             db.url: jdbc_url
           error-status: _thrown
         metrics:
-          '[service/in/responsetime]':
+          service_in_responsetime:
             value: servicegraph_duration
             data-tags:
               origin_service: servicegraph_origin_service_local
               origin_external: servicegraph_origin_external
             constant-tags:
               protocol: servicegraph_protocol
-              error: servicegraph_is_error
+              error: servicegraph_is_error

components/inspectit-ocelot-configdocsgenerator/src/test/resources/ConfigDocGeneratorTest/rules.yml

@@ -5,9 +5,8 @@ inspectit:
         # if true, the free disk space will be measured and the view "disk/free" is registered
         free: true
     definitions:
-      '[disk/free]':
+      disk_free:
         enabled: ${inspectit.metrics.disk.enabled.free}
-        type: LONG
-        max-values-per-tag: 5
+        max-values-per-attribute: 5
         unit: bytes
         description: free disk space

components/inspectit-ocelot-configdocsgenerator/src/test/resources/ConfigParserTest/configWithPlaceholder.yml

@@ -9,6 +9,7 @@ dependencies {
     implementation(
             project(':inspectit-ocelot-config'),
             libs.ioOpentelemetryOpentelemetryApi,
+            libs.ioOpentelemetryOpentelemetrySdkMetrics,
 
             // We chose this generator, because it has a great feature set and is actively maintained
             configServerLibs.comGithubVictoolsJsonschemaGenerator,

components/inspectit-ocelot-configschemagenerator/build.gradle

@@ -47,7 +47,7 @@ void pastList() {
 
             List<String> result = completer.getSuggestions(input);
 
-            assertThat(result).containsExactlyInAnyOrder("config", "exporters", "instrumentation", "instrumentation-feedback", "logging", "metrics", "plugins", "privacy", "publish-open-telemetry-to-bootstrap", "self-monitoring", "service-name", "tags", "thread-pool-size", "tracing", "agent-commands", "log-preloading");
+            assertThat(result).containsExactlyInAnyOrder("config", "exporters", "instrumentation", "instrumentation-feedback", "logging", "metrics", "plugins", "privacy", "publish-open-telemetry-to-bootstrap", "self-monitoring", "service-name", "attributes", "thread-pool-size", "tracing", "agent-commands", "log-preloading");
         }
 
         @Test
@@ -61,7 +61,7 @@ void endsInWildcard() {
 
         @Test
         void endsInEnum() {
-            List<String> input = Arrays.asList("inspectit", "tracing", "add-common-tags");
+            List<String> input = Arrays.asList("inspectit", "tracing", "add-common-attributes");
 
             List<String> result = completer.getSuggestions(input);
 
@@ -74,7 +74,7 @@ void endsInEnum() {
 
         @Test
         void propertyIsPresentAndReadMethodIsNull() {
-            List<String> input = Arrays.asList("inspectit", "instrumentation", "data", "method_duration", "is-tag");
+            List<String> input = Arrays.asList("inspectit", "instrumentation", "data", "method_duration", "session-storage");
 
             List<String> result = completer.getSuggestions(input);
 
@@ -152,7 +152,7 @@ public class GetProperties {
         void getPropertiesInspectit() {
             List<String> result = completer.getProperties(InspectitConfig.class);
 
-            assertThat(result).containsExactlyInAnyOrder("config", "env", "exporters", "instrumentation", "instrumentation-feedback", "logging", "metrics", "plugins", "privacy", "publish-open-telemetry-to-bootstrap", "self-monitoring", "service-name", "tags", "thread-pool-size", "tracing", "agent-commands", "log-preloading");
+            assertThat(result).containsExactlyInAnyOrder("config", "env", "exporters", "instrumentation", "instrumentation-feedback", "logging", "metrics", "plugins", "privacy", "publish-open-telemetry-to-bootstrap", "self-monitoring", "service-name", "attributes", "thread-pool-size", "tracing", "agent-commands", "log-preloading");
         }
     }
 }