add mutex for namespace creation

cloudtruth · Jan 20, 2022 · 87645e7 · 87645e7
1 parent 217639a
commit 87645e7
Showing 1 changed file with 11 additions and 8 deletions.
diff --git a/lib/kubetruth/kubeapi.rb b/lib/kubetruth/kubeapi.rb
@@ -47,6 +47,7 @@ def initialize(namespace: nil, token: nil, api_url: nil)
 
       @api_url = api_url || 'https://kubernetes.default.svc'
       @api_clients = {}
+      @namespace_mutex = Mutex.new
     end
 
     def api_url(api)
@@ -79,14 +80,16 @@ def apiVersion_client(apiVersion)
     end
 
     def ensure_namespace(ns = namespace)
-      begin
-        client.get_namespace(ns)
-      rescue Kubeclient::ResourceNotFoundError
-        newns = Kubeclient::Resource.new
-        newns.metadata = {}
-        newns.metadata.name = ns
-        set_managed(newns)
-        client.create_namespace(newns)
+      @namespace_mutex.synchronize do
+        begin
+          client.get_namespace(ns)
+        rescue Kubeclient::ResourceNotFoundError
+          newns = Kubeclient::Resource.new
+          newns.metadata = {}
+          newns.metadata.name = ns
+          set_managed(newns)
+          client.create_namespace(newns)
+        end
       end
     end