Report all set configuration sources to telemetry

dd-smoke-tests/log-injection/src/main/java/datadog/smoketest/loginjection/BaseApplication.java

@@ -44,7 +44,8 @@ public void run() throws InterruptedException {
   }
 
   private static Object getLogInjectionEnabled() {
-    ConfigSetting configSetting = ConfigCollector.get().collect().get(LOGS_INJECTION_ENABLED);
+    ConfigSetting configSetting =
+        ConfigCollector.get().getAppliedConfigSetting(LOGS_INJECTION_ENABLED);
     if (configSetting == null) {
       return null;
     }

internal-api/src/main/java/datadog/trace/api/ConfigCollector.java

@@ -16,42 +16,50 @@ public class ConfigCollector {
   private static final AtomicReferenceFieldUpdater<ConfigCollector, Map> COLLECTED_UPDATER =
       AtomicReferenceFieldUpdater.newUpdater(ConfigCollector.class, Map.class, "collected");
 
-  private volatile Map<String, ConfigSetting> collected = new ConcurrentHashMap<>();
+  private volatile Map<String, Map<ConfigOrigin, ConfigSetting>> collected =
+      new ConcurrentHashMap<>();
 
   public static ConfigCollector get() {
     return INSTANCE;
   }
 
+  /**
+   * Records the latest ConfigSetting for the given key and origin, replacing any previous value for
+   * that (key, origin) pair.
+   */
   public void put(String key, Object value, ConfigOrigin origin) {
     ConfigSetting setting = ConfigSetting.of(key, value, origin);
-    collected.put(key, setting);
+    Map<ConfigOrigin, ConfigSetting> originMap =
+        collected.computeIfAbsent(key, k -> new ConcurrentHashMap<>());
+    originMap.put(origin, setting); // replaces any previous value for this origin
   }
 
   public void putAll(Map<String, Object> keysAndValues, ConfigOrigin origin) {
-    // attempt merge+replace to avoid collector seeing partial update
-    Map<String, ConfigSetting> merged =
-        new ConcurrentHashMap<>(keysAndValues.size() + collected.size());
     for (Map.Entry<String, Object> entry : keysAndValues.entrySet()) {
-      ConfigSetting setting = ConfigSetting.of(entry.getKey(), entry.getValue(), origin);
-      merged.put(entry.getKey(), setting);
-    }
-    while (true) {
-      Map<String, ConfigSetting> current = collected;
-      current.forEach(merged::putIfAbsent);
-      if (COLLECTED_UPDATER.compareAndSet(this, current, merged)) {
-        break; // success
-      }
-      // roll back to original update before next attempt
-      merged.keySet().retainAll(keysAndValues.keySet());
+      put(entry.getKey(), entry.getValue(), origin);
     }
   }
 
   @SuppressWarnings("unchecked")
-  public Map<String, ConfigSetting> collect() {
+  public Map<String, Map<ConfigOrigin, ConfigSetting>> collect() {
     if (!collected.isEmpty()) {
       return COLLECTED_UPDATER.getAndSet(this, new ConcurrentHashMap<>());
     } else {
       return Collections.emptyMap();
     }
   }
+
+  /**
+   * Returns the {@link ConfigSetting} with the highest precedence for the given key, or {@code
+   * null} if no setting exists for that key.
+   */
+  public ConfigSetting getAppliedConfigSetting(String key) {
+    Map<ConfigOrigin, ConfigSetting> originMap = collected.get(key);
+    if (originMap == null || originMap.isEmpty()) {
+      return null;
+    }
+    return originMap.values().stream()
+        .max(java.util.Comparator.comparingInt(setting -> setting.origin.precedence))
+        .orElse(null);
+  }
 }

internal-api/src/main/java/datadog/trace/api/ConfigOrigin.java

@@ -4,27 +4,29 @@
 // GeneratedDocumentation/ApiDocs/v2/SchemaDocumentation/Schemas/conf_key_value.md
 public enum ConfigOrigin {
   /** configurations that are set through environment variables */
-  ENV("env_var"),
+  ENV("env_var", 5),
   /** values that are set using remote config */
-  REMOTE("remote_config"),
+  REMOTE("remote_config", 9),
   /** configurations that are set through JVM properties */
-  JVM_PROP("jvm_prop"),
+  JVM_PROP("jvm_prop", 6),
   /** configuration read in the stable config file, managed by users */
-  LOCAL_STABLE_CONFIG("local_stable_config"),
+  LOCAL_STABLE_CONFIG("local_stable_config", 4),
   /** configuration read in the stable config file, managed by fleet */
-  FLEET_STABLE_CONFIG("fleet_stable_config"),
+  FLEET_STABLE_CONFIG("fleet_stable_config", 7),
   /** configurations that are set through the customer application */
-  CODE("code"),
+  CODE("code", 8),
   /** set by the dd.yaml file or json */
-  DD_CONFIG("dd_config"),
+  DD_CONFIG("dd_config", 3),
   /** set for cases where it is difficult/not possible to determine the source of a config. */
-  UNKNOWN("unknown"),
+  UNKNOWN("unknown", 2),
   /** set when the user has not set any configuration for the key (defaults to a value) */
-  DEFAULT("default");
+  DEFAULT("default", 1);
 
   public final String value;
+  public final int precedence;
 
-  ConfigOrigin(String value) {
+  ConfigOrigin(String value, int precedence) {
     this.value = value;
+    this.precedence = precedence;
   }
 }

internal-api/src/main/java/datadog/trace/api/ConfigSetting.java

@@ -116,7 +116,9 @@ public String toString() {
         + ", value="
         + stringValue()
         + ", origin="
-        + origin
+        + origin.value
+        + ", seq_id="
+        + origin.precedence
         + '}';
   }
 }