feat(collector): add Windows platform support for resource metrics

This change adds cross-platform resource usage monitoring with Windows support:

- Create new resource_usage.py module with platform-specific implementations
- Add psutil dependency for Windows systems in pyproject.toml
- Refactor runtime.py to use the new cross-platform resource usage functions
- Implement ResourceUsage class that provides consistent interface across platforms

The implementation gracefully handles platform differences, ensuring consistent
metrics collection on both Unix and Windows environments.

Signed-off-by: Paulo Vital <[email protected]>

Author: pvital

pyproject.toml

@@ -53,7 +53,8 @@ dependencies = [
     "opentelemetry-semantic-conventions>=0.48b0",
     "typing_extensions>=4.12.2",
     "pyyaml>=6.0.2",
-    "setuptools>=69.0.0; python_version >= \"3.12\"", 
+    "setuptools>=69.0.0; python_version >= \"3.12\"",
+    "psutil>=5.9.0; sys_platform == \"win32\"",
 ]
 
 [project.entry-points."instana"]

src/instana/collector/helpers/resource_usage.py

@@ -0,0 +1,126 @@
+# (c) Copyright IBM Corp. 2025
+
+"""Cross-platform resource usage information"""
+
+import os
+from typing import NamedTuple
+
+from instana.log import logger
+from instana.util.runtime import is_windows
+
+
+class ResourceUsage(NamedTuple):
+    """Cross-platform resource usage information"""
+
+    ru_utime: float = 0.0
+    ru_stime: float = 0.0
+    ru_maxrss: int = 0
+    ru_ixrss: int = 0
+    ru_idrss: int = 0
+    ru_isrss: int = 0
+    ru_minflt: int = 0
+    ru_majflt: int = 0
+    ru_nswap: int = 0
+    ru_inblock: int = 0
+    ru_oublock: int = 0
+    ru_msgsnd: int = 0
+    ru_msgrcv: int = 0
+    ru_nsignals: int = 0
+    ru_nvcsw: int = 0
+    ru_nivcsw: int = 0
+
+
+def get_resource_usage() -> ResourceUsage:
+    """Get resource usage in a cross-platform way"""
+    if is_windows():
+        return _get_windows_resource_usage()
+    else:
+        return _get_unix_resource_usage()
+
+
+def _get_unix_resource_usage() -> ResourceUsage:
+    """Get resource usage on Unix systems"""
+    import resource
+
+    rusage = resource.getrusage(resource.RUSAGE_SELF)
+
+    return ResourceUsage(
+        ru_utime=rusage.ru_utime,
+        ru_stime=rusage.ru_stime,
+        ru_maxrss=rusage.ru_maxrss,
+        ru_ixrss=rusage.ru_ixrss,
+        ru_idrss=rusage.ru_idrss,
+        ru_isrss=rusage.ru_isrss,
+        ru_minflt=rusage.ru_minflt,
+        ru_majflt=rusage.ru_majflt,
+        ru_nswap=rusage.ru_nswap,
+        ru_inblock=rusage.ru_inblock,
+        ru_oublock=rusage.ru_oublock,
+        ru_msgsnd=rusage.ru_msgsnd,
+        ru_msgrcv=rusage.ru_msgrcv,
+        ru_nsignals=rusage.ru_nsignals,
+        ru_nvcsw=rusage.ru_nvcsw,
+        ru_nivcsw=rusage.ru_nivcsw,
+    )
+
+
+def _get_windows_resource_usage() -> ResourceUsage:
+    """Get resource usage on Windows systems"""
+    # On Windows, we can use psutil to get some of the metrics
+    # For metrics that aren't available, we return 0
+    try:
+        import psutil
+
+        process = psutil.Process(os.getpid())
+
+        # Get CPU times
+        cpu_times = process.cpu_times()
+
+        # Get memory info
+        memory_info = process.memory_info()
+
+        # Get IO counters
+        io_counters = process.io_counters() if hasattr(process, "io_counters") else None
+
+        # Get context switch counts if available
+        ctx_switches = (
+            process.num_ctx_switches() if hasattr(process, "num_ctx_switches") else None
+        )
+
+        return ResourceUsage(
+            ru_utime=cpu_times.user if hasattr(cpu_times, "user") else 0.0,
+            ru_stime=cpu_times.system if hasattr(cpu_times, "system") else 0.0,
+            ru_maxrss=memory_info.rss // 1024
+            if hasattr(memory_info, "rss")
+            else 0,  # Convert to KB to match Unix
+            ru_ixrss=0,  # Not available on Windows
+            ru_idrss=0,  # Not available on Windows
+            ru_isrss=0,  # Not available on Windows
+            ru_minflt=0,  # Not directly available on Windows
+            ru_majflt=0,  # Not directly available on Windows
+            ru_nswap=0,  # Not available on Windows
+            ru_inblock=io_counters.read_count
+            if io_counters and hasattr(io_counters, "read_count")
+            else 0,
+            ru_oublock=io_counters.write_count
+            if io_counters and hasattr(io_counters, "write_count")
+            else 0,
+            ru_msgsnd=0,  # Not available on Windows
+            ru_msgrcv=0,  # Not available on Windows
+            ru_nsignals=0,  # Not available on Windows
+            ru_nvcsw=ctx_switches.voluntary
+            if ctx_switches and hasattr(ctx_switches, "voluntary")
+            else 0,
+            ru_nivcsw=ctx_switches.involuntary
+            if ctx_switches and hasattr(ctx_switches, "involuntary")
+            else 0,
+        )
+    except ImportError:
+        # If psutil is not available, return zeros
+        logger.debug(
+            "get_windows_resource_usage: psutil is not available, returning zeros"
+        )
+        return ResourceUsage()
+
+
+# Made with Bob

src/instana/collector/helpers/runtime.py

@@ -7,18 +7,18 @@
 import importlib.metadata
 import os
 import platform
-import resource
 import sys
 import threading
 from types import ModuleType
-from typing import Any, Dict, List, Union, Callable
+from typing import Any, Callable, Dict, List, Union
 
+from instana.collector.base import BaseCollector
 from instana.collector.helpers.base import BaseHelper
+from instana.collector.helpers.resource_usage import get_resource_usage
 from instana.log import logger
 from instana.util import DictionaryOfStan
 from instana.util.runtime import determine_service_name
 from instana.version import VERSION
-from instana.collector.base import BaseCollector
 
 PATH_OF_DEPRECATED_INSTALLATION_VIA_HOST_AGENT = "/tmp/.instana/python"
 
@@ -42,7 +42,7 @@ def __init__(
     ) -> None:
         super(RuntimeHelper, self).__init__(collector)
         self.previous = DictionaryOfStan()
-        self.previous_rusage = resource.getrusage(resource.RUSAGE_SELF)
+        self.previous_rusage = get_resource_usage()
 
         if gc.isenabled():
             self.previous_gc_count = gc.get_count()
@@ -83,7 +83,7 @@ def _collect_runtime_metrics(
 
         """ Collect up and return the runtime metrics """
         try:
-            rusage = resource.getrusage(resource.RUSAGE_SELF)
+            rusage = get_resource_usage()
             if gc.isenabled():
                 self._collect_gc_metrics(plugin_data, with_snapshot)