add event probe

Signed-off-by: Sylvain Hellegouarch <[email protected]>

Author: Lawouach

CHANGELOG.md

@@ -4,6 +4,10 @@
 
 [Unreleased]: https://github.com/chaostoolkit/chaostoolkit-kubernetes/compare/0.31.1...HEAD
 
+### Added
+
+* A new probe to list cluster events
+
 ## [0.31.1][] - 2023-10-02
 
 [0.31.1]: https://github.com/chaostoolkit/chaostoolkit-kubernetes/compare/0.31.0...0.31.1

chaosk8s/event/__init__.py

@@ -0,0 +1,29 @@
+import json
+from typing import Any, Dict
+
+from chaoslib.types import Configuration, Secrets
+from kubernetes import client
+
+from chaosk8s import create_k8s_api_client
+
+__all__ = ["get_events"]
+
+
+def get_events(
+    label_selector: str = None,
+    limit: int = 100,
+    configuration: Configuration = None,
+    secrets: Secrets = None,
+) -> Dict[str, Any]:
+    """
+    Retrieve Kubernetes events across all namespaces. If a `label_selector`
+    is set, filter to that selector only.
+    """
+    api = create_k8s_api_client(secrets)
+
+    v1 = client.EventsV1Api(api)
+    ret = v1.list_event_for_all_namespaces(
+        _preload_content=False, label_selector=label_selector, limit=limit
+    )
+
+    return json.loads(ret.read().decode("utf-8"))