auto codegen for URocketMQ

ucloud-bot · web-flow · commit 84ca92780475 · 2021-04-22T20:14:17.000+08:00
diff --git a/docs/services.rst b/docs/services.rst
@@ -129,6 +129,13 @@ UK8S
    :members:
 
 
+URocketMQ
+---------
+
+.. autoclass:: ucloud.services.urocketmq.client.URocketMQClient
+   :members:
+
+
 VPC
 ---
 
diff --git a/ucloud/client.py b/ucloud/client.py
@@ -192,6 +192,16 @@ def uphost(self):
             self.logger,
         )
 
+    def urocketmq(self):
+        from ucloud.services.urocketmq.client import URocketMQClient
+
+        return URocketMQClient(
+            self._auto_config("urocketmq"),
+            self.transport,
+            self.middleware,
+            self.logger,
+        )
+
     def usms(self):
         from ucloud.services.usms.client import USMSClient
 
diff --git a/ucloud/services/urocketmq/__init__.py b/ucloud/services/urocketmq/__init__.py
diff --git a/ucloud/services/urocketmq/client.py b/ucloud/services/urocketmq/client.py
@@ -0,0 +1,117 @@
+""" Code is generated by ucloud-model, DO NOT EDIT IT. """
+
+import typing
+
+
+from ucloud.core.client import Client
+from ucloud.services.urocketmq.schemas import apis
+
+
+class URocketMQClient(Client):
+    def __init__(
+        self, config: dict, transport=None, middleware=None, logger=None
+    ):
+        super(URocketMQClient, self).__init__(
+            config, transport, middleware, logger
+        )
+
+    def create_u_rocket_mq_group(
+        self, req: typing.Optional[dict] = None, **kwargs
+    ) -> dict:
+        """CreateURocketMQGroup - 创建一个 Group, 如果同名 Group 在当前 Service 中已存在, 则会失败.
+
+        **Request**
+
+        - **ProjectId** (str) - (Config) 项目ID。 请参考 `GetProjectList接口 <https://docs.ucloud.cn/api/summary/get_project_list>`_
+        - **Region** (str) - (Config) 地域。 参见  `地域和可用区列表 <https://docs.ucloud.cn/api/summary/regionlist>`_
+        - **Name** (str) - (Required) Group 名称，支持大小写字母、数字及-, _ ，长度1~36
+        - **ServiceId** (str) - (Required) Service ID
+        - **Remark** (str) - Group 描述.
+
+        **Response**
+
+        - **GroupId** (str) - 新建 Group 的 ID
+        - **Message** (str) - 返回信息
+
+        """
+        # build request
+        d = {
+            "ProjectId": self.config.project_id,
+            "Region": self.config.region,
+        }
+        req and d.update(req)
+        d = apis.CreateURocketMQGroupRequestSchema().dumps(d)
+
+        # build options
+        kwargs["max_retries"] = 0  # ignore retry when api is not idempotent
+
+        resp = self.invoke("CreateURocketMQGroup", d, **kwargs)
+        return apis.CreateURocketMQGroupResponseSchema().loads(resp)
+
+    def delete_u_rocket_mq_group(
+        self, req: typing.Optional[dict] = None, **kwargs
+    ) -> dict:
+        """DeleteURocketMQGroup - 删除一个已存在的 Group
+
+        **Request**
+
+        - **ProjectId** (str) - (Config) 项目ID。 请参考 `GetProjectList接口 <https://docs.ucloud.cn/api/summary/get_project_list>`_
+        - **Region** (str) - (Config) 地域。 参见  `地域和可用区列表 <https://docs.ucloud.cn/api/summary/regionlist>`_
+        - **GroupName** (str) - (Required) Group名称
+        - **ServiceId** (str) - (Required) Service ID
+
+        **Response**
+
+        - **Message** (str) - 返回信息
+
+        """
+        # build request
+        d = {
+            "ProjectId": self.config.project_id,
+            "Region": self.config.region,
+        }
+        req and d.update(req)
+        d = apis.DeleteURocketMQGroupRequestSchema().dumps(d)
+
+        resp = self.invoke("DeleteURocketMQGroup", d, **kwargs)
+        return apis.DeleteURocketMQGroupResponseSchema().loads(resp)
+
+    def list_u_rocket_mq_group(
+        self, req: typing.Optional[dict] = None, **kwargs
+    ) -> dict:
+        """ListURocketMQGroup - 获取一个 RocketMQ 服务下的所有 Group
+
+        **Request**
+
+        - **ProjectId** (str) - (Config) 项目ID。 请参考 `GetProjectList接口 <https://docs.ucloud.cn/api/summary/get_project_list>`_
+        - **Region** (str) - (Config) 地域。 参见  `地域和可用区列表 <https://docs.ucloud.cn/api/summary/regionlist>`_
+        - **ServiceId** (str) - (Required) Service ID
+        - **Limit** (int) - 最多返回的条目数量, (0, 1000], 默认 50 条
+        - **Offset** (int) - 查询起始位置, [0, ∞)
+
+        **Response**
+
+        - **GroupList** (list) - 见 **GroupBaseInfo** 模型定义
+        - **Message** (str) - 返回信息
+        - **TotalCount** (int) - 记录总数
+
+        **Response Model**
+
+        **GroupBaseInfo**
+        - **CreateTime** (int) - Group 创建时间
+        - **GroupName** (str) - Group 名称
+        - **Id** (str) - Group ID
+        - **Remark** (str) - Group 描述
+
+
+        """
+        # build request
+        d = {
+            "ProjectId": self.config.project_id,
+            "Region": self.config.region,
+        }
+        req and d.update(req)
+        d = apis.ListURocketMQGroupRequestSchema().dumps(d)
+
+        resp = self.invoke("ListURocketMQGroup", d, **kwargs)
+        return apis.ListURocketMQGroupResponseSchema().loads(resp)
diff --git a/ucloud/services/urocketmq/schemas/__init__.py b/ucloud/services/urocketmq/schemas/__init__.py
diff --git a/ucloud/services/urocketmq/schemas/apis.py b/ucloud/services/urocketmq/schemas/apis.py
@@ -0,0 +1,93 @@
+""" Code is generated by ucloud-model, DO NOT EDIT IT. """
+
+
+from ucloud.core.typesystem import schema, fields
+from ucloud.services.urocketmq.schemas import models
+
+""" URocketMQ API Schema
+"""
+
+
+"""
+API: CreateURocketMQGroup
+
+创建一个 Group, 如果同名 Group 在当前 Service 中已存在, 则会失败.
+"""
+
+
+class CreateURocketMQGroupRequestSchema(schema.RequestSchema):
+    """CreateURocketMQGroup - 创建一个 Group, 如果同名 Group 在当前 Service 中已存在, 则会失败."""
+
+    fields = {
+        "Name": fields.Str(required=True, dump_to="Name"),
+        "ProjectId": fields.Str(required=True, dump_to="ProjectId"),
+        "Region": fields.Str(required=True, dump_to="Region"),
+        "Remark": fields.Str(required=False, dump_to="Remark"),
+        "ServiceId": fields.Str(required=True, dump_to="ServiceId"),
+    }
+
+
+class CreateURocketMQGroupResponseSchema(schema.ResponseSchema):
+    """CreateURocketMQGroup - 创建一个 Group, 如果同名 Group 在当前 Service 中已存在, 则会失败."""
+
+    fields = {
+        "GroupId": fields.Str(required=True, load_from="GroupId"),
+        "Message": fields.Str(required=False, load_from="Message"),
+    }
+
+
+"""
+API: DeleteURocketMQGroup
+
+删除一个已存在的 Group
+"""
+
+
+class DeleteURocketMQGroupRequestSchema(schema.RequestSchema):
+    """DeleteURocketMQGroup - 删除一个已存在的 Group"""
+
+    fields = {
+        "GroupName": fields.Str(required=True, dump_to="GroupName"),
+        "ProjectId": fields.Str(required=True, dump_to="ProjectId"),
+        "Region": fields.Str(required=True, dump_to="Region"),
+        "ServiceId": fields.Str(required=True, dump_to="ServiceId"),
+    }
+
+
+class DeleteURocketMQGroupResponseSchema(schema.ResponseSchema):
+    """DeleteURocketMQGroup - 删除一个已存在的 Group"""
+
+    fields = {
+        "Message": fields.Str(required=False, load_from="Message"),
+    }
+
+
+"""
+API: ListURocketMQGroup
+
+获取一个 RocketMQ 服务下的所有 Group
+"""
+
+
+class ListURocketMQGroupRequestSchema(schema.RequestSchema):
+    """ListURocketMQGroup - 获取一个 RocketMQ 服务下的所有 Group"""
+
+    fields = {
+        "Limit": fields.Int(required=False, dump_to="Limit"),
+        "Offset": fields.Int(required=False, dump_to="Offset"),
+        "ProjectId": fields.Str(required=True, dump_to="ProjectId"),
+        "Region": fields.Str(required=True, dump_to="Region"),
+        "ServiceId": fields.Str(required=True, dump_to="ServiceId"),
+    }
+
+
+class ListURocketMQGroupResponseSchema(schema.ResponseSchema):
+    """ListURocketMQGroup - 获取一个 RocketMQ 服务下的所有 Group"""
+
+    fields = {
+        "GroupList": fields.List(
+            models.GroupBaseInfoSchema(), required=False, load_from="GroupList"
+        ),
+        "Message": fields.Str(required=False, load_from="Message"),
+        "TotalCount": fields.Int(required=False, load_from="TotalCount"),
+    }
diff --git a/ucloud/services/urocketmq/schemas/models.py b/ucloud/services/urocketmq/schemas/models.py
@@ -0,0 +1,14 @@
+""" Code is generated by ucloud-model, DO NOT EDIT IT. """
+
+from ucloud.core.typesystem import schema, fields
+
+
+class GroupBaseInfoSchema(schema.ResponseSchema):
+    """GroupBaseInfo - Group基础信息"""
+
+    fields = {
+        "CreateTime": fields.Int(required=True, load_from="CreateTime"),
+        "GroupName": fields.Str(required=True, load_from="GroupName"),
+        "Id": fields.Str(required=True, load_from="Id"),
+        "Remark": fields.Str(required=True, load_from="Remark"),
+    }
