Add metric filtering capability (#1728)

* Add metric filtering capability

* Change enums to uppercase

* Spotbugs

Author: trask

agent/agent-tooling/spotbugs.exclude.xml

@@ -99,7 +99,14 @@
     </Match>
     <Match>
         <Bug pattern="NP_UNWRITTEN_PUBLIC_OR_PROTECTED_FIELD" />
-        <Class name="com.microsoft.applicationinsights.agent.internal.processors.SpanProcessor" />
-        <Method name="create" />
+        <Or>
+            <And>
+                <Class name="com.microsoft.applicationinsights.agent.internal.processors.SpanProcessor" />
+                <Method name="create" />
+            </And>
+            <And>
+                <Class name="com.microsoft.applicationinsights.agent.internal.wasbootstrap.configuration.Configuration$ProcessorIncludeExclude" />
+            </And>
+        </Or>
     </Match>
 </FindBugsFilter>

agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/AiComponentInstaller.java

@@ -66,6 +66,7 @@
 import java.net.URI;
 import java.util.ArrayList;
 import java.util.concurrent.CountDownLatch;
+import java.util.stream.Collectors;
 
 import static java.util.concurrent.TimeUnit.MINUTES;
 import static java.util.concurrent.TimeUnit.SECONDS;
@@ -154,6 +155,10 @@ private static void start(Instrumentation instrumentation) {
         TelemetryConfigurationFactory.INSTANCE.initialize(configuration, buildXmlConfiguration(config));
         configuration.getContextInitializers().add(new SdkVersionContextInitializer());
         configuration.getContextInitializers().add(new ResourceAttributesContextInitializer(config.customDimensions));
+        configuration.setMetricFilters(config.preview.processors.stream()
+                .filter(processor -> processor.type == Configuration.ProcessorType.METRIC_FILTER)
+                .map(Configuration.ProcessorConfig::toMetricFilter)
+                .collect(Collectors.toList()));
 
         try {
             ConnectionString.updateStatsbeatConnectionString(config.internal.statsbeat.instrumentationKey, config.internal.statsbeat.endpoint, configuration);

agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/processors/AgentProcessor.java

@@ -46,7 +46,7 @@ public AgentProcessor(@Nullable IncludeExclude include,
     }
 
     protected static AttributeProcessor.IncludeExclude getNormalizedIncludeExclude(ProcessorIncludeExclude includeExclude) {
-        return includeExclude.matchType == MatchType.strict ? AgentProcessor.StrictIncludeExclude.create(includeExclude) : AgentProcessor.RegexpIncludeExclude.create(includeExclude);
+        return includeExclude.matchType == MatchType.STRICT ? AgentProcessor.StrictIncludeExclude.create(includeExclude) : AgentProcessor.RegexpIncludeExclude.create(includeExclude);
     }
 
     public @Nullable IncludeExclude getInclude() {

agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/processors/AttributeProcessor.java

@@ -77,15 +77,15 @@ public SpanData processActions(SpanData span) {
 
     private SpanData processAction(SpanData span, ProcessorAction actionObj) {
         switch (actionObj.action) {
-            case insert:
+            case INSERT:
                 return processInsertAction(span, actionObj);
-            case update:
+            case UPDATE:
                 return processUpdateAction(span, actionObj);
-            case delete:
+            case DELETE:
                 return processDeleteAction(span, actionObj);
-            case hash:
+            case HASH:
                 return procesHashAction(span, actionObj);
-            case extract:
+            case EXTRACT:
                 return processExtractAction(span, actionObj);
             default:
                 return span;

agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/sampling/SamplingOverrides.java

@@ -144,9 +144,9 @@ private boolean matches(Attributes attributes) {
         }
 
         private static Predicate<Attributes> toPredicate(SamplingOverrideAttribute attribute) {
-            if (attribute.matchType == MatchType.strict) {
+            if (attribute.matchType == MatchType.STRICT) {
                 return new StrictMatcher(attribute.key, attribute.value);
-            } else if (attribute.matchType == MatchType.regexp) {
+            } else if (attribute.matchType == MatchType.REGEXP) {
                 return new RegexpMatcher(attribute.key, attribute.value);
             } else {
                 throw new IllegalStateException("Unexpected match type: " + attribute.matchType);

agent/agent-tooling/src/main/java/com/microsoft/applicationinsights/agent/internal/wasbootstrap/OpenTelemetryConfigurer.java

@@ -19,6 +19,7 @@
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
+import java.util.stream.Collectors;
 
 public class OpenTelemetryConfigurer implements SdkTracerProviderConfigurer {
 
@@ -43,7 +44,9 @@ public void configure(SdkTracerProviderBuilder tracerProvider) {
             // and the default for DelegatingSampler is to not sample anything)
         }
 
-        List<ProcessorConfig> processors = new ArrayList<>(config.preview.processors);
+        List<ProcessorConfig> processors = config.preview.processors.stream()
+                .filter(processor -> processor.type != Configuration.ProcessorType.METRIC_FILTER)
+                .collect(Collectors.toCollection(ArrayList::new));
         // Reversing the order of processors before passing it to SpanProcessor
         Collections.reverse(processors);
 
@@ -53,13 +56,13 @@ public void configure(SdkTracerProviderBuilder tracerProvider) {
             for (ProcessorConfig processorConfig : processors) {
                 if (processorConfig.type != null) { // Added this condition to resolve spotbugs NP_UNWRITTEN_PUBLIC_OR_PROTECTED_FIELD issue
                     switch (processorConfig.type) {
-                        case attribute:
+                        case ATTRIBUTE:
                             currExporter = new ExporterWithAttributeProcessor(processorConfig, currExporter);
                             break;
-                        case span:
+                        case SPAN:
                             currExporter = new ExporterWithSpanProcessor(processorConfig, currExporter);
                             break;
-                        case log:
+                        case LOG:
                             currExporter = new ExporterWithLogProcessor(processorConfig, currExporter);
                             break;
                         default: