Implementation of the open feature SDK in the java tracer (#9885)

Implement OpenFeature Provider interface

Author: manuel-alvarez-alvarez

.github/CODEOWNERS

@@ -115,6 +115,9 @@
 **/datastreams/                                                              @DataDog/data-streams-monitoring
 **/DataStreams*                                                              @DataDog/data-streams-monitoring
 
+# @DataDog/feature-flagging-and-experimentation-sdk
+/products/feature-flagging/                           @DataDog/feature-flagging-and-experimentation-sdk
+
 # @DataDog/profiling-java
 /dd-java-agent/agent-profiling/                                                             @DataDog/profiling-java
 /dd-java-agent/agent-crashtracking/                                                         @DataDog/profiling-java

dd-java-agent/agent-bootstrap/src/main/java/datadog/trace/bootstrap/Agent.java

@@ -32,6 +32,7 @@
 import datadog.trace.api.config.CrashTrackingConfig;
 import datadog.trace.api.config.CwsConfig;
 import datadog.trace.api.config.DebuggerConfig;
+import datadog.trace.api.config.FeatureFlaggingConfig;
 import datadog.trace.api.config.GeneralConfig;
 import datadog.trace.api.config.IastConfig;
 import datadog.trace.api.config.JmxFetchConfig;
@@ -125,7 +126,8 @@ private enum AgentFeature {
     DATA_JOBS(GeneralConfig.DATA_JOBS_ENABLED, false),
     AGENTLESS_LOG_SUBMISSION(GeneralConfig.AGENTLESS_LOG_SUBMISSION_ENABLED, false),
     LLMOBS(LlmObsConfig.LLMOBS_ENABLED, false),
-    LLMOBS_AGENTLESS(LlmObsConfig.LLMOBS_AGENTLESS_ENABLED, false);
+    LLMOBS_AGENTLESS(LlmObsConfig.LLMOBS_AGENTLESS_ENABLED, false),
+    FEATURE_FLAGGING(FeatureFlaggingConfig.FLAGGING_PROVIDER_ENABLED, false);
 
     private final String configKey;
     private final String systemProp;
@@ -184,6 +186,7 @@ public boolean isEnabledByDefault() {
   private static boolean codeOriginEnabled = false;
   private static boolean distributedDebuggerEnabled = false;
   private static boolean agentlessLogSubmissionEnabled = false;
+  private static boolean featureFlaggingEnabled = false;
 
   private static void safelySetContextClassLoader(ClassLoader classLoader) {
     try {
@@ -268,6 +271,7 @@ public static void start(
     codeOriginEnabled = isFeatureEnabled(AgentFeature.CODE_ORIGIN);
     agentlessLogSubmissionEnabled = isFeatureEnabled(AgentFeature.AGENTLESS_LOG_SUBMISSION);
     llmObsEnabled = isFeatureEnabled(AgentFeature.LLMOBS);
+    featureFlaggingEnabled = isFeatureEnabled(AgentFeature.FEATURE_FLAGGING);
 
     // setup writers when llmobs is enabled to accomodate apm and llmobs
     if (llmObsEnabled) {
@@ -662,6 +666,7 @@ public void execute() {
       maybeStartDebugger(instrumentation, scoClass, sco);
       maybeStartRemoteConfig(scoClass, sco);
       maybeStartAiGuard();
+      maybeStartFeatureFlagging(scoClass, sco);
 
       if (telemetryEnabled) {
         startTelemetry(instrumentation, scoClass, sco);
@@ -1083,6 +1088,23 @@ private static void maybeStartLLMObs(Instrumentation inst, Class<?> scoClass, Ob
     }
   }
 
+  private static void maybeStartFeatureFlagging(final Class<?> scoClass, final Object sco) {
+    if (featureFlaggingEnabled) {
+      StaticEventLogger.begin("Feature Flagging");
+
+      try {
+        final Class<?> ffSysClass =
+            AGENT_CLASSLOADER.loadClass("com.datadog.featureflag.FeatureFlaggingSystem");
+        final Method ffSysMethod = ffSysClass.getMethod("start", scoClass);
+        ffSysMethod.invoke(null, sco);
+      } catch (final Throwable e) {
+        log.warn("Not starting Feature Flagging subsystem", e);
+      }
+
+      StaticEventLogger.end("Feature Flagging");
+    }
+  }
+
   private static void maybeInstallLogsIntake(Class<?> scoClass, Object sco) {
     if (agentlessLogSubmissionEnabled) {
       StaticEventLogger.begin("Logs Intake");

dd-java-agent/build.gradle

@@ -189,6 +189,7 @@ includeSubprojShadowJar(project(':dd-java-agent:agent-ci-visibility'), 'ci-visib
 includeSubprojShadowJar(project(':dd-java-agent:agent-llmobs'), 'llm-obs', includedJarFileTree)
 includeSubprojShadowJar(project(':dd-java-agent:agent-logs-intake'), 'logs-intake', includedJarFileTree)
 includeSubprojShadowJar(project(':dd-java-agent:cws-tls'), 'cws-tls', includedJarFileTree)
+includeSubprojShadowJar(project(':products:feature-flagging:agent'), 'feature-flagging', includedJarFileTree)
 
 def sharedShadowJar = tasks.register('sharedShadowJar', ShadowJar) {
   it.configurations = [project.configurations.sharedShadowInclude]
@@ -318,6 +319,7 @@ dependencies {
   shadowInclude project(path: ':dd-java-agent:agent-bootstrap')
   shadowInclude project(path: ':dd-java-agent:agent-debugger:debugger-bootstrap')
   shadowInclude project(path: ':dd-java-agent:agent-otel:otel-bootstrap', configuration: 'shadow')
+  shadowInclude project(path: ':products:feature-flagging:bootstrap')
 
   // Includes for the shared internal shadow jar
   sharedShadowInclude deps.shared

dd-trace-api/build.gradle.kts

@@ -35,6 +35,7 @@ val excludedClassesCoverage by extra(
     "datadog.trace.api.civisibility.noop.NoOpDDTestSession",
     "datadog.trace.api.civisibility.noop.NoOpDDTestSuite",
     "datadog.trace.api.config.AIGuardConfig",
+    "datadog.trace.api.config.FeatureFlaggingConfig",
     "datadog.trace.api.config.ProfilingConfig",
     "datadog.trace.api.interceptor.MutableSpan",
     "datadog.trace.api.profiling.Profiling",

dd-trace-api/src/main/java/datadog/trace/api/config/FeatureFlaggingConfig.java

@@ -0,0 +1,6 @@
+package datadog.trace.api.config;
+
+public class FeatureFlaggingConfig {
+
+  public static final String FLAGGING_PROVIDER_ENABLED = "experimental.flagging.provider.enabled";
+}

gradle/dependencies.gradle

@@ -20,6 +20,7 @@ final class CachedData {
       exclude(project(':components:environment'))
       exclude(project(':components:json'))
       exclude(project(':components:yaml'))
+      exclude(project(':products:feature-flagging:bootstrap'))
       exclude(project(':remote-config:remote-config-api'))
       exclude(project(':remote-config:remote-config-core'))
       exclude(project(':telemetry'))

internal-api/src/main/java/datadog/trace/api/intake/Intake.java

@@ -15,13 +15,18 @@ public enum Intake {
       "ci-intake",
       "v2",
       Config::isCiVisibilityAgentlessEnabled,
-      Config::getCiVisibilityIntakeAgentlessUrl);
+      Config::getCiVisibilityIntakeAgentlessUrl),
+  EVENT_PLATFORM("event-platform-intake", "v2");
 
   public final String urlPrefix;
   public final String version;
   public final Function<Config, Boolean> agentlessModeEnabled;
   public final Function<Config, String> customUrl;
 
+  Intake(String urlPrefix, String version) {
+    this(urlPrefix, version, config -> false, config -> null);
+  }
+
   Intake(
       String urlPrefix,
       String version,

internal-api/src/main/java/datadog/trace/util/AgentThreadFactory.java

@@ -59,7 +59,9 @@ public enum AgentThread {
 
     LOGS_INTAKE("dd-logs-intake"),
 
-    LLMOBS_EVALS_PROCESSOR("dd-llmobs-evals-processor");
+    LLMOBS_EVALS_PROCESSOR("dd-llmobs-evals-processor"),
+
+    FEATURE_FLAG_EXPOSURE_PROCESSOR("dd-ffe-exposure-processor");
 
     public final String threadName;
 

metadata/supported-configurations.json

@@ -184,6 +184,7 @@
     "DD_EXCEPTION_REPLAY_MAX_FRAMES_TO_CAPTURE": ["A"],
     "DD_EXPERIMENTAL_API_SECURITY_ENABLED": ["A"],
     "DD_EXPERIMENTAL_DEFER_INTEGRATIONS_UNTIL": ["A"],
+    "DD_EXPERIMENTAL_FLAGGING_PROVIDER_ENABLED": ["A"],
     "DD_EXPERIMENTAL_PROPAGATE_PROCESS_TAGS_ENABLED": ["A"],
     "DD_FORCE_CLEAR_TEXT_HTTP_FOR_INTAKE_CLIENT": ["A"],
     "DD_GIT_BRANCH": ["A"],

products/feature-flagging/agent/build.gradle.kts

@@ -0,0 +1,30 @@
+import com.github.jengelman.gradle.plugins.shadow.tasks.ShadowJar
+import org.gradle.kotlin.dsl.project
+
+plugins {
+  `java-library`
+  id("com.gradleup.shadow")
+}
+
+apply(from = "$rootDir/gradle/java.gradle")
+apply(from = "$rootDir/gradle/version.gradle")
+
+description = "Feature flagging agent system"
+
+dependencies {
+  api(libs.slf4j)
+  api(project(":products:feature-flagging:lib"))
+  api(project(":internal-api"))
+
+  testImplementation(project(":utils:test-utils"))
+  testRuntimeOnly(project(":dd-trace-core"))
+}
+
+tasks.named<ShadowJar>("shadowJar") {
+  dependencies {
+    val deps = project.extra["deps"] as Map<*, *>
+    val excludeShared = deps["excludeShared"] as groovy.lang.Closure<*>
+    excludeShared.delegate = this
+    excludeShared.call()
+  }
+}