client.rb in tencentcloud-sdk-cls-3.0.605

- old
+ new

@@ -75,10 +75,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 本接口用于校验Kafka服务集群是否可以正常访问
+
+        # @param request: Request instance for CheckRechargeKafkaServer.
+        # @type request: :class:`Tencentcloud::cls::V20201016::CheckRechargeKafkaServerRequest`
+        # @rtype: :class:`Tencentcloud::cls::V20201016::CheckRechargeKafkaServerResponse`
+        def CheckRechargeKafkaServer(request)
+          body = send_request('CheckRechargeKafkaServer', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = CheckRechargeKafkaServerResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 关闭Kafka协议消费
 
         # @param request: Request instance for CloseKafkaConsumer.
         # @type request: :class:`Tencentcloud::cls::V20201016::CloseKafkaConsumerRequest`
         # @rtype: :class:`Tencentcloud::cls::V20201016::CloseKafkaConsumerResponse`
@@ -291,10 +315,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 本接口用于创建Kafka数据订阅任务
+
+        # @param request: Request instance for CreateKafkaRecharge.
+        # @type request: :class:`Tencentcloud::cls::V20201016::CreateKafkaRechargeRequest`
+        # @rtype: :class:`Tencentcloud::cls::V20201016::CreateKafkaRechargeResponse`
+        def CreateKafkaRecharge(request)
+          body = send_request('CreateKafkaRecharge', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = CreateKafkaRechargeResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 本接口用于创建日志集，返回新创建的日志集的 ID。
 
         # @param request: Request instance for CreateLogset.
         # @type request: :class:`Tencentcloud::cls::V20201016::CreateLogsetRequest`
         # @rtype: :class:`Tencentcloud::cls::V20201016::CreateLogsetResponse`
@@ -579,10 +627,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 本接口用于删除Kafka数据订阅任务
+
+        # @param request: Request instance for DeleteKafkaRecharge.
+        # @type request: :class:`Tencentcloud::cls::V20201016::DeleteKafkaRechargeRequest`
+        # @rtype: :class:`Tencentcloud::cls::V20201016::DeleteKafkaRechargeResponse`
+        def DeleteKafkaRecharge(request)
+          body = send_request('DeleteKafkaRecharge', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = DeleteKafkaRechargeResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 本接口用于删除日志集。
 
         # @param request: Request instance for DeleteLogset.
         # @type request: :class:`Tencentcloud::cls::V20201016::DeleteLogsetRequest`
         # @rtype: :class:`Tencentcloud::cls::V20201016::DeleteLogsetResponse`
@@ -939,10 +1011,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 本接口用于获取Kafka数据订阅任务
+
+        # @param request: Request instance for DescribeKafkaRecharges.
+        # @type request: :class:`Tencentcloud::cls::V20201016::DescribeKafkaRechargesRequest`
+        # @rtype: :class:`Tencentcloud::cls::V20201016::DescribeKafkaRechargesResponse`
+        def DescribeKafkaRecharges(request)
+          body = send_request('DescribeKafkaRecharges', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = DescribeKafkaRechargesResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 本接口用于搜索日志上下文附近的内容
 
         # @param request: Request instance for DescribeLogContext.
         # @type request: :class:`Tencentcloud::cls::V20201016::DescribeLogContextRequest`
         # @rtype: :class:`Tencentcloud::cls::V20201016::DescribeLogContextResponse`
@@ -1395,10 +1491,34 @@
           raise e
         rescue StandardError => e
           raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
         end
 
+        # 本接口用于修改Kafka数据订阅任务
+
+        # @param request: Request instance for ModifyKafkaRecharge.
+        # @type request: :class:`Tencentcloud::cls::V20201016::ModifyKafkaRechargeRequest`
+        # @rtype: :class:`Tencentcloud::cls::V20201016::ModifyKafkaRechargeResponse`
+        def ModifyKafkaRecharge(request)
+          body = send_request('ModifyKafkaRecharge', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = ModifyKafkaRechargeResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
         # 本接口用于修改日志集信息
 
         # @param request: Request instance for ModifyLogset.
         # @type request: :class:`Tencentcloud::cls::V20201016::ModifyLogsetRequest`
         # @rtype: :class:`Tencentcloud::cls::V20201016::ModifyLogsetResponse`
@@ -1501,9 +1621,33 @@
         def OpenKafkaConsumer(request)
           body = send_request('OpenKafkaConsumer', request.serialize)
           response = JSON.parse(body)
           if response['Response'].key?('Error') == false
             model = OpenKafkaConsumerResponse.new
+            model.deserialize(response['Response'])
+            model
+          else
+            code = response['Response']['Error']['Code']
+            message = response['Response']['Error']['Message']
+            reqid = response['Response']['RequestId']
+            raise TencentCloud::Common::TencentCloudSDKException.new(code, message, reqid)
+          end
+        rescue TencentCloud::Common::TencentCloudSDKException => e
+          raise e
+        rescue StandardError => e
+          raise TencentCloud::Common::TencentCloudSDKException.new(nil, e.inspect)
+        end
+
+        # 本接口用于预览Kafka数据订阅任务客户日志信息
+
+        # @param request: Request instance for PreviewKafkaRecharge.
+        # @type request: :class:`Tencentcloud::cls::V20201016::PreviewKafkaRechargeRequest`
+        # @rtype: :class:`Tencentcloud::cls::V20201016::PreviewKafkaRechargeResponse`
+        def PreviewKafkaRecharge(request)
+          body = send_request('PreviewKafkaRecharge', request.serialize)
+          response = JSON.parse(body)
+          if response['Response'].key?('Error') == false
+            model = PreviewKafkaRechargeResponse.new
             model.deserialize(response['Response'])
             model
           else
             code = response['Response']['Error']['Code']
             message = response['Response']['Error']['Message']
\ No newline at end of file