Exporter Release 1.0.0b43: Add CONSUMER to perf counters (#43261)

* Add CONSUMER to perf counters and release

* changelog

* update date

Author: jeremydvoss

sdk/monitor/azure-monitor-opentelemetry-exporter/CHANGELOG.md

@@ -1,6 +1,6 @@
 # Release History
 
-## 1.0.0b43 (Unreleased)
+## 1.0.0b43 (2025-10-08)
 
 ### Features Added
 - OneSettings control plane: Add live metrics feature control
@@ -11,8 +11,8 @@
   ([#43147](https://github.com/Azure/azure-sdk-for-python/pull/43147))
 - Performance Counters
   ([#43024](https://github.com/Azure/azure-sdk-for-python/pull/43024))
-
-### Breaking Changes
+- Performance Counters: Include Consumer spans
+  ([#43261](https://github.com/Azure/azure-sdk-for-python/pull/43261))
 
 ### Bugs Fixed
 - Fixes issues #42897 - TypeError in _transmit_from_storage: LocalFileBlob.get() returns None
@@ -26,8 +26,6 @@
 - Revert #43060
   ([#43087](https://github.com/Azure/azure-sdk-for-python/pull/43087))
 
-### Other Changes
-
 ## 1.0.0b42 (2025-09-17)
 
 ### Features Added

sdk/monitor/azure-monitor-opentelemetry-exporter/azure/monitor/opentelemetry/exporter/_performance_counters/_manager.py

@@ -616,8 +616,8 @@ def _record_span(self, span: ReadableSpan) -> None:
             global _REQUESTS_COUNT
             # pylint: disable=global-statement
             global _EXCEPTIONS_COUNT
-            # Requests only
-            if span.kind != SpanKind.SERVER:
+            # Requests and Consumer only
+            if span.kind not in (SpanKind.SERVER, SpanKind.CONSUMER):
                 return
             _REQUESTS_COUNT += 1
             duration_ms = 0

sdk/monitor/azure-monitor-opentelemetry-exporter/tests/performance_counters/test_performance_counters.py

@@ -448,6 +448,34 @@ def test_manager_singleton_behavior(self):
 
         self.assertIs(manager1, manager2)
 
+    @mock.patch("azure.monitor.opentelemetry.exporter._performance_counters._manager.metrics.get_meter_provider")
+    def test_record_span_consumer(self, mock_get_meter_provider):
+        """Test recording span for requests."""
+        mock_meter_provider = MagicMock()
+        mock_meter = MagicMock()
+        mock_meter_provider.get_meter.return_value = mock_meter
+        mock_get_meter_provider.return_value = mock_meter_provider
+        
+        manager = _PerformanceCountersManager()
+        manager._request_duration_histogram = MagicMock()
+        
+        # Create a mock span
+        mock_span = MagicMock(spec=ReadableSpan)
+        mock_span.kind = SpanKind.CONSUMER
+        mock_span.start_time = 1000000000  # 1 second in nanoseconds
+        mock_span.end_time = 2000000000    # 2 seconds in nanoseconds
+        mock_span.events = []
+        
+        # Import to access global counter
+        import azure.monitor.opentelemetry.exporter._performance_counters._manager as manager_module
+        initial_count = manager_module._REQUESTS_COUNT
+        
+        manager._record_span(mock_span)
+        
+        # Check that request was counted and duration recorded
+        self.assertEqual(manager_module._REQUESTS_COUNT, initial_count + 1)
+        manager._request_duration_histogram.record.assert_called_once_with(1.0)  # 1 second duration
+
     @mock.patch("azure.monitor.opentelemetry.exporter._performance_counters._manager.metrics.get_meter_provider")
     def test_record_span_request(self, mock_get_meter_provider):
         """Test recording span for requests."""
@@ -506,7 +534,7 @@ def test_record_span_with_exception(self, mock_get_meter_provider):
         # Check that exception was counted
         self.assertEqual(manager_module._EXCEPTIONS_COUNT, initial_exceptions + 1)
 
-    def test_record_span_non_server_kind(self):
+    def test_record_span_non_server_consumer_kind(self):
         """Test recording span that's not a server/consumer kind."""
         manager = _PerformanceCountersManager()