Add diagnostic events tracker

Author: keelerm84

ldclient/client.py

@@ -284,6 +284,9 @@ def __start_up(self, start_wait: float):
             log.info("Started LaunchDarkly Client in LDD mode")
 
         diagnostic_accumulator = self._set_event_processor(self._config)
+        
+        # Pass diagnostic accumulator to data system for streaming metrics
+        self._data_system.set_diagnostic_accumulator(diagnostic_accumulator)
 
         self.__register_plugins(environment_metadata)
 

ldclient/impl/datasystem/fdv1.py

@@ -75,6 +75,9 @@ def __init__(self, config: Config):
 
         # Update processor created in start(), because it needs the ready Event
         self._update_processor: Optional[UpdateProcessor] = None
+        
+        # Diagnostic accumulator provided by client for streaming metrics
+        self._diagnostic_accumulator = None
 
         # Track current data availability
         self._data_availability: DataAvailability = (
@@ -118,6 +121,13 @@ def set_flag_value_eval_fn(self, eval_fn):
         (key: str, context: Context) -> Any.
         """
         self._flag_tracker_impl = FlagTrackerImpl(self._flag_change_listeners, eval_fn)
+    
+    def set_diagnostic_accumulator(self, diagnostic_accumulator):
+        """
+        Sets the diagnostic accumulator for streaming initialization metrics.
+        This should be called before start() to ensure metrics are collected.
+        """
+        self._diagnostic_accumulator = diagnostic_accumulator
 
     @property
     def data_source_status_provider(self) -> DataSourceStatusProvider:
@@ -151,8 +161,7 @@ def _make_update_processor(self, config: Config, store: FeatureStore, ready: Eve
             return NullUpdateProcessor(config, store, ready)
 
         if config.stream:
-            # Diagnostic accumulator is handled in client; pass None here
-            return StreamingUpdateProcessor(config, store, ready, None)
+            return StreamingUpdateProcessor(config, store, ready, self._diagnostic_accumulator)
 
         # Polling mode
         feature_requester = (