collect telemetry where configs are defined

ddtrace/settings/_core.py

@@ -0,0 +1,19 @@
+from envier.env import EnvVariable
+from envier.env import _normalized
+
+from ddtrace.internal.telemetry import telemetry_writer
+
+
+def report_telemetry(env):
+    for name, e in list(env.__class__.__dict__.items()):
+        if isinstance(e, EnvVariable) and not e.private:
+            env_name = env._full_prefix + _normalized(e.name)
+            env_val = e(env, env._full_prefix)
+            raw_val = env.source.get(env_name)
+            if env_name in env.source and env_val == e._cast(e.type, raw_val, env):
+                source = "env_var"
+            elif env_val == e.default:
+                source = "default"
+            else:
+                source = "unknown"
+            telemetry_writer.add_configuration(env_name, str(env_val), source)

ddtrace/settings/asm.py

@@ -17,6 +17,7 @@
 from ddtrace.constants import APPSEC_ENV
 from ddtrace.constants import IAST_ENV
 from ddtrace.internal.utils.deprecations import DDTraceDeprecationWarning
+from ddtrace.settings._core import report_telemetry as _report_telemetry
 from ddtrace.vendor.debtcollector import deprecate
 
 
@@ -231,6 +232,7 @@ def _user_event_mode(self) -> str:
 
 
 config = ASMConfig()
+_report_telemetry(config)
 
 if not config._asm_libddwaf_available:
     config._asm_enabled = False

ddtrace/settings/crashtracker.py

@@ -3,6 +3,7 @@
 from envier import En
 
 from ddtrace.internal.utils.formats import parse_tags_str
+from ddtrace.settings._core import report_telemetry as _report_telemetry
 
 
 resolver_default = "full"
@@ -111,3 +112,4 @@ class CrashtrackingConfig(En):
 
 
 config = CrashtrackingConfig()
+_report_telemetry(config)

ddtrace/settings/dynamic_instrumentation.py

@@ -8,6 +8,7 @@
 from ddtrace.internal.constants import DEFAULT_SERVICE_NAME
 from ddtrace.internal.utils.config import get_application_name
 from ddtrace.settings import _config as ddconfig
+from ddtrace.settings._core import report_telemetry as _report_telemetry
 from ddtrace.version import get_version
 
 
@@ -131,3 +132,4 @@ class DynamicInstrumentationConfig(En):
 
 
 config = DynamicInstrumentationConfig()
+_report_telemetry(config)

ddtrace/settings/exception_replay.py

@@ -1,5 +1,7 @@
 from envier import En
 
+from ddtrace.settings._core import report_telemetry as _report_telemetry
+
 
 class ExceptionReplayConfig(En):
     __prefix__ = "dd.exception"
@@ -15,3 +17,4 @@ class ExceptionReplayConfig(En):
 
 
 config = ExceptionReplayConfig()
+_report_telemetry(config)

ddtrace/settings/peer_service.py

@@ -4,6 +4,7 @@
 from ddtrace.internal.schema import SCHEMA_VERSION
 from ddtrace.internal.utils.formats import asbool
 from ddtrace.internal.utils.formats import parse_tags_str
+from ddtrace.settings._core import report_telemetry as _report_telemetry
 
 
 class PeerServiceConfig(object):
@@ -37,3 +38,4 @@ def peer_service_mapping(self):
 
 
 _ps_config = PeerServiceConfig()
+_report_telemetry(_ps_config)

ddtrace/settings/profiling.py

@@ -13,6 +13,7 @@
 from ddtrace.internal import gitmetadata
 from ddtrace.internal.logger import get_logger
 from ddtrace.internal.utils.formats import parse_tags_str
+from ddtrace.settings._core import report_telemetry as _report_telemetry
 
 
 logger = get_logger(__name__)
@@ -418,6 +419,7 @@ class ProfilingConfigExport(En):
 ProfilingConfig.include(ProfilingConfigExport, namespace="export")
 
 config = ProfilingConfig()
+_report_telemetry(config)
 
 # If during processing we discover that the configuration was injected, we need to do a few things
 # - Mark it as such

ddtrace/settings/symbol_db.py

@@ -2,6 +2,8 @@
 
 from envier import En
 
+from ddtrace.settings._core import report_telemetry as _report_telemetry
+
 
 class SymbolDatabaseConfig(En):
     __prefix__ = "dd.symbol_database"
@@ -36,3 +38,4 @@ class SymbolDatabaseConfig(En):
 
 
 config = SymbolDatabaseConfig()
+_report_telemetry(config)