apply: add sample manifests for managedservices

rapyuta-robotics · Dec 6, 2022 · 3b0929e · 3b0929e
1 parent ff8b787
commit 3b0929e
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 5 deletions.
diff --git a/riocli/apply/manifests/deployment.yaml b/riocli/apply/manifests/deployment.yaml
@@ -40,3 +40,7 @@ spec:
     - depends:
         kind: network
         nameOrGUID: "routed"
+  managedServices:
+    - depends:
+        kind: managedservice
+        nameOrGUID: "test-service"
diff --git a/riocli/apply/manifests/managedservice.yaml b/riocli/apply/manifests/managedservice.yaml
@@ -0,0 +1,9 @@
+apiVersion: "apiextensions.rapyuta.io/v1"
+kind: ManagedService
+metadata:
+  name: "elastic-test"
+  labels:
+    creator: riocli
+spec:
+  provider: elasticsearch
+  config: {}
diff --git a/riocli/managedservice/util.py b/riocli/managedservice/util.py
@@ -37,7 +37,7 @@ def list_providers(self):
         data = json.loads(response.text)
         if not response.ok:
             err_msg = data.get('error')
-            raise Exception(err_msg)
+            raise Exception("managedservice: {}".format(err_msg))
         return data.get('items', [])
 
     def list_instances(self):
@@ -52,7 +52,7 @@ def list_instances(self):
             data = json.loads(response.text)
             if not response.ok:
                 err_msg = data.get('error')
-                raise Exception(err_msg)
+                raise Exception("managedservice: {}".format(err_msg))
             instances = data.get('items', [])
             if not instances:
                 break
@@ -69,7 +69,7 @@ def get_instance(self, instance_name: str) -> typing.Dict:
         data = json.loads(response.text)
         if not response.ok:
             err_msg = data.get('error')
-            raise Exception(err_msg)
+            raise Exception("managedservice: {}".format(err_msg))
         return data
 
     def create_instance(self, instance: typing.Any) -> typing.Dict:
@@ -92,7 +92,7 @@ def create_instance(self, instance: typing.Any) -> typing.Dict:
         data = json.loads(response.text)
         if not response.ok:
             err_msg = data.get('error')
-            raise Exception(err_msg)
+            raise Exception("managedservice: {}".format(err_msg))
         return data
 
     def delete_instance(self, instance_name):
@@ -103,5 +103,5 @@ def delete_instance(self, instance_name):
         data = json.loads(response.text)
         if not response.ok:
             err_msg = data.get('error')
-            raise Exception(err_msg)
+            raise Exception("managedservice: {}".format(err_msg))
         return data