Add proxy support to Kubernetes client configuration in get_client

This update modifies the get_client function to support
setting a proxy for the Kubernetes client configuration.
The client_configuration argument is introduced to allow
passing a client.Configuration object directly, and if not
provided, it defaults to creating a new configuration instance.
Additionally, if the HTTPS_PROXY or HTTP_PROXY environment
variables are set, the proxy is applied to the Kubernetes
client configuration.

This enhancement enables easier integration of Kubernetes
client setup when working behind a proxy.

Signed-off-by: Shahaf Bahar <[email protected]>

Author: sbahar619

ocp_resources/resource.py

@@ -79,7 +79,11 @@ def _get_api_version(dyn_client: DynamicClient, api_group: str, kind: str) -> st
 
 
 def get_client(
-    config_file: str = "", config_dict: dict[str, Any] | None = None, context: str = "", **kwargs: Any
+    config_file: str = "",
+    config_dict: dict[str, Any] | None = None,
+    client_configuration: kubernetes.client.Configuration | None = None,
+    context: str = "",
+    **kwargs: Any,
 ) -> DynamicClient:
     """
     Get a kubernetes client.
@@ -95,6 +99,7 @@ def get_client(
     Args:
         config_file (str): path to a kubeconfig file.
         config_dict (dict): dict with kubeconfig configuration.
+        client_configuration (kubernetes.client.Configuration): The kubernetes.client.Configuration to set configs to.
         context (str): name of the context to use.
 
     Returns:
@@ -115,8 +120,17 @@ def get_client(
         # If `KUBECONFIG` environment variable is set via code, the `KUBE_CONFIG_DEFAULT_LOCATION` will be None since
         # is populated during import which comes before setting the variable in code.
         config_file = config_file or os.environ.get("KUBECONFIG", "~/.kube/config")
+        client_configuration = client_configuration or kubernetes.client.Configuration()
+        proxy = os.environ.get("HTTPS_PROXY") or os.environ.get("HTTP_PROXY")
+
+        if proxy:
+            LOGGER.info(f"Setting proxy in client configuration: {proxy}")
+            client_configuration.proxy = proxy
+
         return kubernetes.dynamic.DynamicClient(
-            client=kubernetes.config.new_client_from_config(config_file=config_file, context=context or None, **kwargs)
+            client=kubernetes.config.new_client_from_config(
+                config_file=config_file, client_configuration=client_configuration, context=context or None, **kwargs
+            )
         )
     except MaxRetryError:
         # Ref: https://github.com/kubernetes-client/python/blob/v26.1.0/kubernetes/base/config/incluster_config.py