fix must have config bug

syswu · syswu · commit f83a59184fed · 2024-01-02T14:57:46.000+08:00
diff --git a/kubesys/client.py b/kubesys/client.py
@@ -35,14 +35,15 @@ class KubernetesClient():
     def __init__(self, url=None, token=None, analyzer=None,
                  config=None, relearning=True) -> None:
         # if not url and not token:
-        self.config = readConfig(config)
+        self.config = config
 
         if self.config is None:
             if url is None or token is None:
                 sys.exit('missing url or token')
             self.url = url.rstrip("/")
             self.token = token
         else:
+            self.config = readConfig(config)
             self.url = self.config.server
             self.token = None
 
diff --git a/watch-resources-example.py b/watch-resources-example.py
@@ -0,0 +1,26 @@
+##
+# Copyright (2021, ) Institute of Software, Chinese Academy of Sciences
+##
+import os.path
+
+import yaml
+
+from kubesys.client import KubernetesClient
+from kubesys.common import dictToJsonString, getActiveThreadCount, goodPrintDict
+from kubesys.watch_handler import WatchHandler
+import time
+
+
+def test_watcher(client, namespce, kind):
+    print("--start to watch...")
+    client.watchResources(kind=kind, namespace=namespce, watcherhandler=WatchHandler(
+        add_func=lambda json_dict: print(kind, "ADDED ", dictToJsonString(json_dict)[:20]),
+        modify_func=lambda json_dict: print(kind, "MODIFIED ", dictToJsonString(json_dict)[:20]),
+        delete_func=lambda json_dict: print(kind, "DELETED ", dictToJsonString(json_dict)[:20])))
+    time.sleep(10000)
+
+
+if __name__ == '__main__':
+    client = KubernetesClient(url="https://133.133.135.193:8443",
+                              token="")
+    test_watcher(client=client, namespce="", kind="Pod")
