# frozen_string_literal: true # Copyright (c) 2017-2018 THL A29 Limited, a Tencent company. All Rights Reserved. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. # You may obtain a copy of the License at # # http://www.apache.org/licenses/LICENSE-2.0 # # Unless required by applicable law or agreed to in writing, software # distributed under the License is distributed on an "AS IS" BASIS, # WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. # See the License for the specific language governing permissions and # limitations under the License. module TencentCloud module Trocket module V20230308 # 消费组信息 class ConsumeGroupItem < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param ConsumerGroup: 消费组名称 # @type ConsumerGroup: String # @param ConsumeEnable: 是否开启消费 # @type ConsumeEnable: Boolean # @param ConsumeMessageOrderly: 顺序投递:true # 并发投递:false # @type ConsumeMessageOrderly: Boolean # @param MaxRetryTimes: 最大重试次数 # @type MaxRetryTimes: Integer # @param Remark: 备注 # @type Remark: String attr_accessor :InstanceId, :ConsumerGroup, :ConsumeEnable, :ConsumeMessageOrderly, :MaxRetryTimes, :Remark def initialize(instanceid=nil, consumergroup=nil, consumeenable=nil, consumemessageorderly=nil, maxretrytimes=nil, remark=nil) @InstanceId = instanceid @ConsumerGroup = consumergroup @ConsumeEnable = consumeenable @ConsumeMessageOrderly = consumemessageorderly @MaxRetryTimes = maxretrytimes @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @ConsumerGroup = params['ConsumerGroup'] @ConsumeEnable = params['ConsumeEnable'] @ConsumeMessageOrderly = params['ConsumeMessageOrderly'] @MaxRetryTimes = params['MaxRetryTimes'] @Remark = params['Remark'] end end # CreateConsumerGroup请求参数结构体 class CreateConsumerGroupRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param ConsumerGroup: 消费组名称 # @type ConsumerGroup: String # @param MaxRetryTimes: 最大重试次数 # @type MaxRetryTimes: Integer # @param ConsumeEnable: 是否开启消费 # @type ConsumeEnable: Boolean # @param ConsumeMessageOrderly: 顺序投递:true # 并发投递:false # @type ConsumeMessageOrderly: Boolean # @param Remark: 备注 # @type Remark: String attr_accessor :InstanceId, :ConsumerGroup, :MaxRetryTimes, :ConsumeEnable, :ConsumeMessageOrderly, :Remark def initialize(instanceid=nil, consumergroup=nil, maxretrytimes=nil, consumeenable=nil, consumemessageorderly=nil, remark=nil) @InstanceId = instanceid @ConsumerGroup = consumergroup @MaxRetryTimes = maxretrytimes @ConsumeEnable = consumeenable @ConsumeMessageOrderly = consumemessageorderly @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @ConsumerGroup = params['ConsumerGroup'] @MaxRetryTimes = params['MaxRetryTimes'] @ConsumeEnable = params['ConsumeEnable'] @ConsumeMessageOrderly = params['ConsumeMessageOrderly'] @Remark = params['Remark'] end end # CreateConsumerGroup返回参数结构体 class CreateConsumerGroupResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param ConsumerGroup: 消费组 # @type ConsumerGroup: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :ConsumerGroup, :RequestId def initialize(instanceid=nil, consumergroup=nil, requestid=nil) @InstanceId = instanceid @ConsumerGroup = consumergroup @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @ConsumerGroup = params['ConsumerGroup'] @RequestId = params['RequestId'] end end # CreateInstance请求参数结构体 class CreateInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceType: 实例类型, # EXPERIMENT 体验版 # BASIC 基础版 # PRO 专业版 # PLATINUM 铂金版 # @type InstanceType: String # @param Name: 实例名称 # @type Name: String # @param SkuCode: 商品规格,可用规格如下: # experiment_500, # basic_1k, # basic_2k, # basic_4k, # basic_6k, # pro_4k, # pro_6k, # pro_1w, # pro_2w, # pro_3w, # pro_4w, # pro_5w, # platinum_6k, # platinum_1w, # platinum_2w, # platinum_4w, # platinum_10w, # platinum_15w, # platinum_20w, # platinum_40w, # platinum_60w, # platinum_100w # @type SkuCode: String # @param Remark: 备注信息 # @type Remark: String # @param TagList: 标签列表 # @type TagList: Array # @param VpcList: 实例绑定的VPC信息 # @type VpcList: Array # @param EnablePublic: 是否开启公网 # @type EnablePublic: Boolean # @param Bandwidth: 公网带宽(单位:兆) # @type Bandwidth: Integer # @param IpRules: 公网访问白名单 # @type IpRules: Array # @param MessageRetention: 消息保留时长(单位:小时) # @type MessageRetention: Integer # @param PayMode: 付费模式(0: 后付费;1: 预付费) # @type PayMode: Integer # @param RenewFlag: 是否自动续费(0: 不自动续费;1: 自动续费) # @type RenewFlag: Integer # @param TimeSpan: 购买时长(单位:月) # @type TimeSpan: Integer # @param MaxTopicNum: 最大可创建主题数 # @type MaxTopicNum: Integer attr_accessor :InstanceType, :Name, :SkuCode, :Remark, :TagList, :VpcList, :EnablePublic, :Bandwidth, :IpRules, :MessageRetention, :PayMode, :RenewFlag, :TimeSpan, :MaxTopicNum def initialize(instancetype=nil, name=nil, skucode=nil, remark=nil, taglist=nil, vpclist=nil, enablepublic=nil, bandwidth=nil, iprules=nil, messageretention=nil, paymode=nil, renewflag=nil, timespan=nil, maxtopicnum=nil) @InstanceType = instancetype @Name = name @SkuCode = skucode @Remark = remark @TagList = taglist @VpcList = vpclist @EnablePublic = enablepublic @Bandwidth = bandwidth @IpRules = iprules @MessageRetention = messageretention @PayMode = paymode @RenewFlag = renewflag @TimeSpan = timespan @MaxTopicNum = maxtopicnum end def deserialize(params) @InstanceType = params['InstanceType'] @Name = params['Name'] @SkuCode = params['SkuCode'] @Remark = params['Remark'] unless params['TagList'].nil? @TagList = [] params['TagList'].each do |i| tag_tmp = Tag.new tag_tmp.deserialize(i) @TagList << tag_tmp end end unless params['VpcList'].nil? @VpcList = [] params['VpcList'].each do |i| vpcinfo_tmp = VpcInfo.new vpcinfo_tmp.deserialize(i) @VpcList << vpcinfo_tmp end end @EnablePublic = params['EnablePublic'] @Bandwidth = params['Bandwidth'] unless params['IpRules'].nil? @IpRules = [] params['IpRules'].each do |i| iprule_tmp = IpRule.new iprule_tmp.deserialize(i) @IpRules << iprule_tmp end end @MessageRetention = params['MessageRetention'] @PayMode = params['PayMode'] @RenewFlag = params['RenewFlag'] @TimeSpan = params['TimeSpan'] @MaxTopicNum = params['MaxTopicNum'] end end # CreateInstance返回参数结构体 class CreateInstanceResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :RequestId def initialize(instanceid=nil, requestid=nil) @InstanceId = instanceid @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @RequestId = params['RequestId'] end end # CreateMQTTInsPublicEndpoint请求参数结构体 class CreateMQTTInsPublicEndpointRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Bandwidth: 带宽 # @type Bandwidth: Integer # @param Rules: 公网访问规则 # @type Rules: Array attr_accessor :InstanceId, :Bandwidth, :Rules def initialize(instanceid=nil, bandwidth=nil, rules=nil) @InstanceId = instanceid @Bandwidth = bandwidth @Rules = rules end def deserialize(params) @InstanceId = params['InstanceId'] @Bandwidth = params['Bandwidth'] unless params['Rules'].nil? @Rules = [] params['Rules'].each do |i| publicaccessrule_tmp = PublicAccessRule.new publicaccessrule_tmp.deserialize(i) @Rules << publicaccessrule_tmp end end end end # CreateMQTTInsPublicEndpoint返回参数结构体 class CreateMQTTInsPublicEndpointResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # CreateMQTTInstance请求参数结构体 class CreateMQTTInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceType: 实例类型, # EXPERIMENT 体验版 # BASIC 基础版 # PRO 专业版 # PLATINUM 铂金版 # @type InstanceType: String # @param Name: 实例名称 # @type Name: String # @param SkuCode: 商品规格,可用规格如下: # experiment_500, # basic_1k, # basic_2k, # basic_4k, # basic_6k, # pro_4k, # pro_6k, # pro_1w, # pro_2w, # pro_3w, # pro_4w, # pro_5w, # platinum_6k, # platinum_1w, # platinum_2w, # platinum_4w, # platinum_10w, # platinum_15w, # platinum_20w, # platinum_40w, # platinum_60w, # platinum_100w # @type SkuCode: String # @param Remark: 备注信息 # @type Remark: String # @param TagList: 标签列表 # @type TagList: Array # @param VpcList: 实例绑定的VPC信息 # @type VpcList: Array # @param EnablePublic: 是否开启公网 # @type EnablePublic: Boolean # @param Bandwidth: 公网带宽(单位:兆) # @type Bandwidth: Integer # @param IpRules: 公网访问白名单 # @type IpRules: Array # @param RenewFlag: 是否自动续费(0: 不自动续费;1: 自动续费) # @type RenewFlag: Integer # @param TimeSpan: 购买时长(单位:月) # @type TimeSpan: Integer attr_accessor :InstanceType, :Name, :SkuCode, :Remark, :TagList, :VpcList, :EnablePublic, :Bandwidth, :IpRules, :RenewFlag, :TimeSpan def initialize(instancetype=nil, name=nil, skucode=nil, remark=nil, taglist=nil, vpclist=nil, enablepublic=nil, bandwidth=nil, iprules=nil, renewflag=nil, timespan=nil) @InstanceType = instancetype @Name = name @SkuCode = skucode @Remark = remark @TagList = taglist @VpcList = vpclist @EnablePublic = enablepublic @Bandwidth = bandwidth @IpRules = iprules @RenewFlag = renewflag @TimeSpan = timespan end def deserialize(params) @InstanceType = params['InstanceType'] @Name = params['Name'] @SkuCode = params['SkuCode'] @Remark = params['Remark'] unless params['TagList'].nil? @TagList = [] params['TagList'].each do |i| tag_tmp = Tag.new tag_tmp.deserialize(i) @TagList << tag_tmp end end unless params['VpcList'].nil? @VpcList = [] params['VpcList'].each do |i| vpcinfo_tmp = VpcInfo.new vpcinfo_tmp.deserialize(i) @VpcList << vpcinfo_tmp end end @EnablePublic = params['EnablePublic'] @Bandwidth = params['Bandwidth'] unless params['IpRules'].nil? @IpRules = [] params['IpRules'].each do |i| iprule_tmp = IpRule.new iprule_tmp.deserialize(i) @IpRules << iprule_tmp end end @RenewFlag = params['RenewFlag'] @TimeSpan = params['TimeSpan'] end end # CreateMQTTInstance返回参数结构体 class CreateMQTTInstanceResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :RequestId def initialize(instanceid=nil, requestid=nil) @InstanceId = instanceid @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @RequestId = params['RequestId'] end end # CreateMQTTTopic请求参数结构体 class CreateMQTTTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param Remark: 备注 # @type Remark: String attr_accessor :InstanceId, :Topic, :Remark def initialize(instanceid=nil, topic=nil, remark=nil) @InstanceId = instanceid @Topic = topic @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @Remark = params['Remark'] end end # CreateMQTTTopic返回参数结构体 class CreateMQTTTopicResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :Topic, :RequestId def initialize(instanceid=nil, topic=nil, requestid=nil) @InstanceId = instanceid @Topic = topic @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @RequestId = params['RequestId'] end end # CreateMQTTUser请求参数结构体 class CreateMQTTUserRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Remark: 备注 # @type Remark: String # @param PermWrite: 是否开启生产权限 # @type PermWrite: Boolean # @param PermRead: 是否开启消费权限 # @type PermRead: Boolean # @param Username: 用户名 # @type Username: String # @param Password: 密码,该字段为空时候则后端会默认生成 # @type Password: String attr_accessor :InstanceId, :Remark, :PermWrite, :PermRead, :Username, :Password def initialize(instanceid=nil, remark=nil, permwrite=nil, permread=nil, username=nil, password=nil) @InstanceId = instanceid @Remark = remark @PermWrite = permwrite @PermRead = permread @Username = username @Password = password end def deserialize(params) @InstanceId = params['InstanceId'] @Remark = params['Remark'] @PermWrite = params['PermWrite'] @PermRead = params['PermRead'] @Username = params['Username'] @Password = params['Password'] end end # CreateMQTTUser返回参数结构体 class CreateMQTTUserResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # CreateRole请求参数结构体 class CreateRoleRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Role: 角色名称 # @type Role: String # @param Remark: 备注 # @type Remark: String # @param PermWrite: 是否开启生产权限 # @type PermWrite: Boolean # @param PermRead: 是否开启消费权限 # @type PermRead: Boolean attr_accessor :InstanceId, :Role, :Remark, :PermWrite, :PermRead def initialize(instanceid=nil, role=nil, remark=nil, permwrite=nil, permread=nil) @InstanceId = instanceid @Role = role @Remark = remark @PermWrite = permwrite @PermRead = permread end def deserialize(params) @InstanceId = params['InstanceId'] @Role = params['Role'] @Remark = params['Remark'] @PermWrite = params['PermWrite'] @PermRead = params['PermRead'] end end # CreateRole返回参数结构体 class CreateRoleResponse < TencentCloud::Common::AbstractModel # @param Role: 角色名 # @type Role: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Role, :RequestId def initialize(role=nil, requestid=nil) @Role = role @RequestId = requestid end def deserialize(params) @Role = params['Role'] @RequestId = params['RequestId'] end end # CreateTopic请求参数结构体 class CreateTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param TopicType: 主题类型 # UNSPECIFIED:未指定, # NORMAL:普通消息, # FIFO:顺序消息, # DELAY:延时消息, # TRANSACTION:事务消息 # @type TopicType: String # @param QueueNum: 队列数量 # @type QueueNum: Integer # @param Remark: 备注 # @type Remark: String # @param MsgTTL: 消息保留时长 # @type MsgTTL: Integer attr_accessor :InstanceId, :Topic, :TopicType, :QueueNum, :Remark, :MsgTTL def initialize(instanceid=nil, topic=nil, topictype=nil, queuenum=nil, remark=nil, msgttl=nil) @InstanceId = instanceid @Topic = topic @TopicType = topictype @QueueNum = queuenum @Remark = remark @MsgTTL = msgttl end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @TopicType = params['TopicType'] @QueueNum = params['QueueNum'] @Remark = params['Remark'] @MsgTTL = params['MsgTTL'] end end # CreateTopic返回参数结构体 class CreateTopicResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :Topic, :RequestId def initialize(instanceid=nil, topic=nil, requestid=nil) @InstanceId = instanceid @Topic = topic @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @RequestId = params['RequestId'] end end # map结构返回 class CustomMapEntry < TencentCloud::Common::AbstractModel # @param Key: key # 注意:此字段可能返回 null,表示取不到有效值。 # @type Key: String # @param Value: value # 注意:此字段可能返回 null,表示取不到有效值。 # @type Value: String attr_accessor :Key, :Value def initialize(key=nil, value=nil) @Key = key @Value = value end def deserialize(params) @Key = params['Key'] @Value = params['Value'] end end # DeleteConsumerGroup请求参数结构体 class DeleteConsumerGroupRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param ConsumerGroup: 消费组名称 # @type ConsumerGroup: String attr_accessor :InstanceId, :ConsumerGroup def initialize(instanceid=nil, consumergroup=nil) @InstanceId = instanceid @ConsumerGroup = consumergroup end def deserialize(params) @InstanceId = params['InstanceId'] @ConsumerGroup = params['ConsumerGroup'] end end # DeleteConsumerGroup返回参数结构体 class DeleteConsumerGroupResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DeleteInstance请求参数结构体 class DeleteInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DeleteInstance返回参数结构体 class DeleteInstanceResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DeleteMQTTInsPublicEndpoint请求参数结构体 class DeleteMQTTInsPublicEndpointRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DeleteMQTTInsPublicEndpoint返回参数结构体 class DeleteMQTTInsPublicEndpointResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DeleteMQTTInstance请求参数结构体 class DeleteMQTTInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DeleteMQTTInstance返回参数结构体 class DeleteMQTTInstanceResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DeleteMQTTTopic请求参数结构体 class DeleteMQTTTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String attr_accessor :InstanceId, :Topic def initialize(instanceid=nil, topic=nil) @InstanceId = instanceid @Topic = topic end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] end end # DeleteMQTTTopic返回参数结构体 class DeleteMQTTTopicResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DeleteMQTTUser请求参数结构体 class DeleteMQTTUserRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Username: 用户名 # @type Username: String attr_accessor :InstanceId, :Username def initialize(instanceid=nil, username=nil) @InstanceId = instanceid @Username = username end def deserialize(params) @InstanceId = params['InstanceId'] @Username = params['Username'] end end # DeleteMQTTUser返回参数结构体 class DeleteMQTTUserResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DeleteRole请求参数结构体 class DeleteRoleRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Role: 角色名称 # @type Role: String attr_accessor :InstanceId, :Role def initialize(instanceid=nil, role=nil) @InstanceId = instanceid @Role = role end def deserialize(params) @InstanceId = params['InstanceId'] @Role = params['Role'] end end # DeleteRole返回参数结构体 class DeleteRoleResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DeleteTopic请求参数结构体 class DeleteTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String attr_accessor :InstanceId, :Topic def initialize(instanceid=nil, topic=nil) @InstanceId = instanceid @Topic = topic end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] end end # DeleteTopic返回参数结构体 class DeleteTopicResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # DescribeConsumerGroupList请求参数结构体 class DescribeConsumerGroupListRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer # @param Filters: 查询条件列表 # @type Filters: Array # @param FromTopic: 查询指定主题下的消费组 # @type FromTopic: String attr_accessor :InstanceId, :Offset, :Limit, :Filters, :FromTopic def initialize(instanceid=nil, offset=nil, limit=nil, filters=nil, fromtopic=nil) @InstanceId = instanceid @Offset = offset @Limit = limit @Filters = filters @FromTopic = fromtopic end def deserialize(params) @InstanceId = params['InstanceId'] @Offset = params['Offset'] @Limit = params['Limit'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @FromTopic = params['FromTopic'] end end # DescribeConsumerGroupList返回参数结构体 class DescribeConsumerGroupListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 消费组列表 # @type Data: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :RequestId def initialize(totalcount=nil, data=nil, requestid=nil) @TotalCount = totalcount @Data = data @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| consumegroupitem_tmp = ConsumeGroupItem.new consumegroupitem_tmp.deserialize(i) @Data << consumegroupitem_tmp end end @RequestId = params['RequestId'] end end # DescribeConsumerGroup请求参数结构体 class DescribeConsumerGroupRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param ConsumerGroup: 消费组名称 # @type ConsumerGroup: String attr_accessor :InstanceId, :ConsumerGroup def initialize(instanceid=nil, consumergroup=nil) @InstanceId = instanceid @ConsumerGroup = consumergroup end def deserialize(params) @InstanceId = params['InstanceId'] @ConsumerGroup = params['ConsumerGroup'] end end # DescribeConsumerGroup返回参数结构体 class DescribeConsumerGroupResponse < TencentCloud::Common::AbstractModel # @param ConsumerNum: 在线消费者数量 # @type ConsumerNum: Integer # @param Tps: TPS # @type Tps: Integer # @param ConsumerLag: 消息堆积数量 # @type ConsumerLag: Integer # @param ConsumeType: 消费者类型 # @type ConsumeType: String # @param CreatedTime: 创建时间,秒为单位 # @type CreatedTime: Integer # @param ConsumeMessageOrderly: 顺序投递:true # 并发投递:false # @type ConsumeMessageOrderly: Boolean # @param ConsumeEnable: 是否开启消费 # @type ConsumeEnable: Boolean # @param MaxRetryTimes: 最大重试次数 # @type MaxRetryTimes: Integer # @param Remark: 备注 # @type Remark: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :ConsumerNum, :Tps, :ConsumerLag, :ConsumeType, :CreatedTime, :ConsumeMessageOrderly, :ConsumeEnable, :MaxRetryTimes, :Remark, :RequestId def initialize(consumernum=nil, tps=nil, consumerlag=nil, consumetype=nil, createdtime=nil, consumemessageorderly=nil, consumeenable=nil, maxretrytimes=nil, remark=nil, requestid=nil) @ConsumerNum = consumernum @Tps = tps @ConsumerLag = consumerlag @ConsumeType = consumetype @CreatedTime = createdtime @ConsumeMessageOrderly = consumemessageorderly @ConsumeEnable = consumeenable @MaxRetryTimes = maxretrytimes @Remark = remark @RequestId = requestid end def deserialize(params) @ConsumerNum = params['ConsumerNum'] @Tps = params['Tps'] @ConsumerLag = params['ConsumerLag'] @ConsumeType = params['ConsumeType'] @CreatedTime = params['CreatedTime'] @ConsumeMessageOrderly = params['ConsumeMessageOrderly'] @ConsumeEnable = params['ConsumeEnable'] @MaxRetryTimes = params['MaxRetryTimes'] @Remark = params['Remark'] @RequestId = params['RequestId'] end end # DescribeInstanceList请求参数结构体 class DescribeInstanceListRequest < TencentCloud::Common::AbstractModel # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer # @param Filters: 查询条件列表 # @type Filters: Array # @param TagFilters: 标签过滤器 # @type TagFilters: Array attr_accessor :Offset, :Limit, :Filters, :TagFilters def initialize(offset=nil, limit=nil, filters=nil, tagfilters=nil) @Offset = offset @Limit = limit @Filters = filters @TagFilters = tagfilters end def deserialize(params) @Offset = params['Offset'] @Limit = params['Limit'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end unless params['TagFilters'].nil? @TagFilters = [] params['TagFilters'].each do |i| tagfilter_tmp = TagFilter.new tagfilter_tmp.deserialize(i) @TagFilters << tagfilter_tmp end end end end # DescribeInstanceList返回参数结构体 class DescribeInstanceListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 实例列表 # @type Data: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :RequestId def initialize(totalcount=nil, data=nil, requestid=nil) @TotalCount = totalcount @Data = data @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| instanceitem_tmp = InstanceItem.new instanceitem_tmp.deserialize(i) @Data << instanceitem_tmp end end @RequestId = params['RequestId'] end end # DescribeInstance请求参数结构体 class DescribeInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DescribeInstance返回参数结构体 class DescribeInstanceResponse < TencentCloud::Common::AbstractModel # @param InstanceType: 实例类型, # EXPERIMENT 体验版 # BASIC 基础版 # PRO 专业版 # PLATINUM 铂金版 # @type InstanceType: String # @param InstanceId: 实例ID # @type InstanceId: String # @param InstanceName: 实例名称 # @type InstanceName: String # @param TopicNum: 主题数量 # @type TopicNum: Integer # @param TopicNumLimit: 实例最大主题数量 # @type TopicNumLimit: Integer # @param GroupNum: 消费组数量 # @type GroupNum: Integer # @param GroupNumLimit: 实例最大消费组数量 # @type GroupNumLimit: Integer # @param MessageRetention: 消息保留时间,小时为单位 # @type MessageRetention: Integer # @param RetentionUpperLimit: 最大可调整消息保留时间,小时为单位 # @type RetentionUpperLimit: Integer # @param RetentionLowerLimit: 最小可调整消息保留时间,小时为单位 # @type RetentionLowerLimit: Integer # @param TpsLimit: TPS限流值 # @type TpsLimit: Integer # @param ScaledTpsLimit: 弹性TPS限流值 # @type ScaledTpsLimit: Integer # @param MaxMessageDelay: 延迟消息最长时间,小时为单位 # @type MaxMessageDelay: Integer # @param CreatedTime: 创建时间,秒为单位 # @type CreatedTime: Integer # @param SendReceiveRatio: 消息发送接收比例 # @type SendReceiveRatio: Float # @param TagList: 标签 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TagList: Array # @param EndpointList: 接入点列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type EndpointList: Array # @param TopicQueueNumUpperLimit: 主题队列数上限 # @type TopicQueueNumUpperLimit: Integer # @param TopicQueueNumLowerLimit: 主题队列数下限 # @type TopicQueueNumLowerLimit: Integer # @param Remark: 备注信息 # @type Remark: String # @param InstanceStatus: 实例状态 # @type InstanceStatus: String # @param SkuCode: 实例规格 # @type SkuCode: String # @param PayMode: 计费模式 # @type PayMode: String # @param ScaledTpsEnabled: 是否开启弹性TPS # @type ScaledTpsEnabled: Boolean # @param RenewFlag: 是否自动续费 # @type RenewFlag: Integer # @param ExpiryTime: 到期时间 # @type ExpiryTime: Integer # @param RoleNumLimit: 角色数量限制 # @type RoleNumLimit: Integer # @param AclEnabled: 是否开启 ACL # 注意:此字段可能返回 null,表示取不到有效值。 # @type AclEnabled: Boolean # @param TopicNumLowerLimit: topic个数免费额度 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicNumLowerLimit: Integer # @param TopicNumUpperLimit: 最大可设置的topic个数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicNumUpperLimit: Integer # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceType, :InstanceId, :InstanceName, :TopicNum, :TopicNumLimit, :GroupNum, :GroupNumLimit, :MessageRetention, :RetentionUpperLimit, :RetentionLowerLimit, :TpsLimit, :ScaledTpsLimit, :MaxMessageDelay, :CreatedTime, :SendReceiveRatio, :TagList, :EndpointList, :TopicQueueNumUpperLimit, :TopicQueueNumLowerLimit, :Remark, :InstanceStatus, :SkuCode, :PayMode, :ScaledTpsEnabled, :RenewFlag, :ExpiryTime, :RoleNumLimit, :AclEnabled, :TopicNumLowerLimit, :TopicNumUpperLimit, :RequestId def initialize(instancetype=nil, instanceid=nil, instancename=nil, topicnum=nil, topicnumlimit=nil, groupnum=nil, groupnumlimit=nil, messageretention=nil, retentionupperlimit=nil, retentionlowerlimit=nil, tpslimit=nil, scaledtpslimit=nil, maxmessagedelay=nil, createdtime=nil, sendreceiveratio=nil, taglist=nil, endpointlist=nil, topicqueuenumupperlimit=nil, topicqueuenumlowerlimit=nil, remark=nil, instancestatus=nil, skucode=nil, paymode=nil, scaledtpsenabled=nil, renewflag=nil, expirytime=nil, rolenumlimit=nil, aclenabled=nil, topicnumlowerlimit=nil, topicnumupperlimit=nil, requestid=nil) @InstanceType = instancetype @InstanceId = instanceid @InstanceName = instancename @TopicNum = topicnum @TopicNumLimit = topicnumlimit @GroupNum = groupnum @GroupNumLimit = groupnumlimit @MessageRetention = messageretention @RetentionUpperLimit = retentionupperlimit @RetentionLowerLimit = retentionlowerlimit @TpsLimit = tpslimit @ScaledTpsLimit = scaledtpslimit @MaxMessageDelay = maxmessagedelay @CreatedTime = createdtime @SendReceiveRatio = sendreceiveratio @TagList = taglist @EndpointList = endpointlist @TopicQueueNumUpperLimit = topicqueuenumupperlimit @TopicQueueNumLowerLimit = topicqueuenumlowerlimit @Remark = remark @InstanceStatus = instancestatus @SkuCode = skucode @PayMode = paymode @ScaledTpsEnabled = scaledtpsenabled @RenewFlag = renewflag @ExpiryTime = expirytime @RoleNumLimit = rolenumlimit @AclEnabled = aclenabled @TopicNumLowerLimit = topicnumlowerlimit @TopicNumUpperLimit = topicnumupperlimit @RequestId = requestid end def deserialize(params) @InstanceType = params['InstanceType'] @InstanceId = params['InstanceId'] @InstanceName = params['InstanceName'] @TopicNum = params['TopicNum'] @TopicNumLimit = params['TopicNumLimit'] @GroupNum = params['GroupNum'] @GroupNumLimit = params['GroupNumLimit'] @MessageRetention = params['MessageRetention'] @RetentionUpperLimit = params['RetentionUpperLimit'] @RetentionLowerLimit = params['RetentionLowerLimit'] @TpsLimit = params['TpsLimit'] @ScaledTpsLimit = params['ScaledTpsLimit'] @MaxMessageDelay = params['MaxMessageDelay'] @CreatedTime = params['CreatedTime'] @SendReceiveRatio = params['SendReceiveRatio'] unless params['TagList'].nil? @TagList = [] params['TagList'].each do |i| tag_tmp = Tag.new tag_tmp.deserialize(i) @TagList << tag_tmp end end unless params['EndpointList'].nil? @EndpointList = [] params['EndpointList'].each do |i| endpoint_tmp = Endpoint.new endpoint_tmp.deserialize(i) @EndpointList << endpoint_tmp end end @TopicQueueNumUpperLimit = params['TopicQueueNumUpperLimit'] @TopicQueueNumLowerLimit = params['TopicQueueNumLowerLimit'] @Remark = params['Remark'] @InstanceStatus = params['InstanceStatus'] @SkuCode = params['SkuCode'] @PayMode = params['PayMode'] @ScaledTpsEnabled = params['ScaledTpsEnabled'] @RenewFlag = params['RenewFlag'] @ExpiryTime = params['ExpiryTime'] @RoleNumLimit = params['RoleNumLimit'] @AclEnabled = params['AclEnabled'] @TopicNumLowerLimit = params['TopicNumLowerLimit'] @TopicNumUpperLimit = params['TopicNumUpperLimit'] @RequestId = params['RequestId'] end end # DescribeMQTTClient请求参数结构体 class DescribeMQTTClientRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param ClientId: 客户端详情 # @type ClientId: String attr_accessor :InstanceId, :ClientId def initialize(instanceid=nil, clientid=nil) @InstanceId = instanceid @ClientId = clientid end def deserialize(params) @InstanceId = params['InstanceId'] @ClientId = params['ClientId'] end end # DescribeMQTTClient返回参数结构体 class DescribeMQTTClientResponse < TencentCloud::Common::AbstractModel # @param ClientId: 客户端唯一标识 # @type ClientId: String # @param ClientAddress: 客户端网络地址 # @type ClientAddress: String # @param ProtocolVersion: MQTT 协议版本,4 表示 MQTT 3.1.1 # @type ProtocolVersion: Integer # @param Keepalive: 保持连接时间,单位:秒 # @type Keepalive: Integer # @param ConnectionStatus: 连接状态,CONNECTED 已连接,DISCONNECTED 未连接 # @type ConnectionStatus: String # @param CreateTime: 客户端创建时间 # @type CreateTime: Integer # @param ConnectTime: 上次建立连接时间 # @type ConnectTime: Integer # @param DisconnectTime: 上次断开连接时间,仅对持久会话(cleanSession=false)并且客户端当前未连接时有意义 # @type DisconnectTime: Integer # @param MQTTClientSubscriptions: 客户端的订阅列表 # @type MQTTClientSubscriptions: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :ClientId, :ClientAddress, :ProtocolVersion, :Keepalive, :ConnectionStatus, :CreateTime, :ConnectTime, :DisconnectTime, :MQTTClientSubscriptions, :RequestId def initialize(clientid=nil, clientaddress=nil, protocolversion=nil, keepalive=nil, connectionstatus=nil, createtime=nil, connecttime=nil, disconnecttime=nil, mqttclientsubscriptions=nil, requestid=nil) @ClientId = clientid @ClientAddress = clientaddress @ProtocolVersion = protocolversion @Keepalive = keepalive @ConnectionStatus = connectionstatus @CreateTime = createtime @ConnectTime = connecttime @DisconnectTime = disconnecttime @MQTTClientSubscriptions = mqttclientsubscriptions @RequestId = requestid end def deserialize(params) @ClientId = params['ClientId'] @ClientAddress = params['ClientAddress'] @ProtocolVersion = params['ProtocolVersion'] @Keepalive = params['Keepalive'] @ConnectionStatus = params['ConnectionStatus'] @CreateTime = params['CreateTime'] @ConnectTime = params['ConnectTime'] @DisconnectTime = params['DisconnectTime'] unless params['MQTTClientSubscriptions'].nil? @MQTTClientSubscriptions = [] params['MQTTClientSubscriptions'].each do |i| mqttclientsubscription_tmp = MQTTClientSubscription.new mqttclientsubscription_tmp.deserialize(i) @MQTTClientSubscriptions << mqttclientsubscription_tmp end end @RequestId = params['RequestId'] end end # DescribeMQTTInsPublicEndpoints请求参数结构体 class DescribeMQTTInsPublicEndpointsRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DescribeMQTTInsPublicEndpoints返回参数结构体 class DescribeMQTTInsPublicEndpointsResponse < TencentCloud::Common::AbstractModel # @param Endpoints: 接入点 # @type Endpoints: Array # @param InstanceId: 实例id # @type InstanceId: String # @param Bandwidth: 带宽 # @type Bandwidth: Integer # @param Rules: 公网访问规则 # @type Rules: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Endpoints, :InstanceId, :Bandwidth, :Rules, :RequestId def initialize(endpoints=nil, instanceid=nil, bandwidth=nil, rules=nil, requestid=nil) @Endpoints = endpoints @InstanceId = instanceid @Bandwidth = bandwidth @Rules = rules @RequestId = requestid end def deserialize(params) unless params['Endpoints'].nil? @Endpoints = [] params['Endpoints'].each do |i| mqttendpointitem_tmp = MQTTEndpointItem.new mqttendpointitem_tmp.deserialize(i) @Endpoints << mqttendpointitem_tmp end end @InstanceId = params['InstanceId'] @Bandwidth = params['Bandwidth'] unless params['Rules'].nil? @Rules = [] params['Rules'].each do |i| publicaccessrule_tmp = PublicAccessRule.new publicaccessrule_tmp.deserialize(i) @Rules << publicaccessrule_tmp end end @RequestId = params['RequestId'] end end # DescribeMQTTInsVPCEndpoints请求参数结构体 class DescribeMQTTInsVPCEndpointsRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DescribeMQTTInsVPCEndpoints返回参数结构体 class DescribeMQTTInsVPCEndpointsResponse < TencentCloud::Common::AbstractModel # @param Endpoints: 接入点 # @type Endpoints: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Endpoints, :RequestId def initialize(endpoints=nil, requestid=nil) @Endpoints = endpoints @RequestId = requestid end def deserialize(params) unless params['Endpoints'].nil? @Endpoints = [] params['Endpoints'].each do |i| mqttendpointitem_tmp = MQTTEndpointItem.new mqttendpointitem_tmp.deserialize(i) @Endpoints << mqttendpointitem_tmp end end @RequestId = params['RequestId'] end end # DescribeMQTTInstanceCert请求参数结构体 class DescribeMQTTInstanceCertRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DescribeMQTTInstanceCert返回参数结构体 class DescribeMQTTInstanceCertResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 集群id # 注意:此字段可能返回 null,表示取不到有效值。 # @type InstanceId: String # @param SSLServerCertId: 服务端证书id # 注意:此字段可能返回 null,表示取不到有效值。 # @type SSLServerCertId: String # @param SSLCaCertId: CA证书id # 注意:此字段可能返回 null,表示取不到有效值。 # @type SSLCaCertId: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :SSLServerCertId, :SSLCaCertId, :RequestId def initialize(instanceid=nil, sslservercertid=nil, sslcacertid=nil, requestid=nil) @InstanceId = instanceid @SSLServerCertId = sslservercertid @SSLCaCertId = sslcacertid @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @SSLServerCertId = params['SSLServerCertId'] @SSLCaCertId = params['SSLCaCertId'] @RequestId = params['RequestId'] end end # DescribeMQTTInstanceList请求参数结构体 class DescribeMQTTInstanceListRequest < TencentCloud::Common::AbstractModel # @param Filters: 查询条件列表 # @type Filters: Array # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer attr_accessor :Filters, :Offset, :Limit def initialize(filters=nil, offset=nil, limit=nil) @Filters = filters @Offset = offset @Limit = limit end def deserialize(params) unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @Offset = params['Offset'] @Limit = params['Limit'] end end # DescribeMQTTInstanceList返回参数结构体 class DescribeMQTTInstanceListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 实例列表 # @type Data: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :RequestId def initialize(totalcount=nil, data=nil, requestid=nil) @TotalCount = totalcount @Data = data @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| mqttinstanceitem_tmp = MQTTInstanceItem.new mqttinstanceitem_tmp.deserialize(i) @Data << mqttinstanceitem_tmp end end @RequestId = params['RequestId'] end end # DescribeMQTTInstance请求参数结构体 class DescribeMQTTInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String attr_accessor :InstanceId def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @InstanceId = params['InstanceId'] end end # DescribeMQTTInstance返回参数结构体 class DescribeMQTTInstanceResponse < TencentCloud::Common::AbstractModel # @param InstanceType: 实例类型, # EXPERIMENT 体验版 # BASIC 基础版 # PRO 专业版 # PLATINUM 铂金版 # @type InstanceType: String # @param InstanceId: 实例ID # @type InstanceId: String # @param InstanceName: 实例名称 # @type InstanceName: String # @param TopicNum: 主题数量 # @type TopicNum: Integer # @param TopicNumLimit: 实例最大主题数量 # @type TopicNumLimit: Integer # @param TpsLimit: TPS限流值 # @type TpsLimit: Integer # @param CreatedTime: 创建时间,秒为单位 # @type CreatedTime: Integer # @param Remark: 备注信息 # @type Remark: String # @param InstanceStatus: 实例状态 # @type InstanceStatus: String # @param SkuCode: 实例规格 # @type SkuCode: String # @param SubscriptionNumLimit: 订阅数上限 # @type SubscriptionNumLimit: Integer # @param ClientNumLimit: 客户端数量上限 # @type ClientNumLimit: Integer # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceType, :InstanceId, :InstanceName, :TopicNum, :TopicNumLimit, :TpsLimit, :CreatedTime, :Remark, :InstanceStatus, :SkuCode, :SubscriptionNumLimit, :ClientNumLimit, :RequestId def initialize(instancetype=nil, instanceid=nil, instancename=nil, topicnum=nil, topicnumlimit=nil, tpslimit=nil, createdtime=nil, remark=nil, instancestatus=nil, skucode=nil, subscriptionnumlimit=nil, clientnumlimit=nil, requestid=nil) @InstanceType = instancetype @InstanceId = instanceid @InstanceName = instancename @TopicNum = topicnum @TopicNumLimit = topicnumlimit @TpsLimit = tpslimit @CreatedTime = createdtime @Remark = remark @InstanceStatus = instancestatus @SkuCode = skucode @SubscriptionNumLimit = subscriptionnumlimit @ClientNumLimit = clientnumlimit @RequestId = requestid end def deserialize(params) @InstanceType = params['InstanceType'] @InstanceId = params['InstanceId'] @InstanceName = params['InstanceName'] @TopicNum = params['TopicNum'] @TopicNumLimit = params['TopicNumLimit'] @TpsLimit = params['TpsLimit'] @CreatedTime = params['CreatedTime'] @Remark = params['Remark'] @InstanceStatus = params['InstanceStatus'] @SkuCode = params['SkuCode'] @SubscriptionNumLimit = params['SubscriptionNumLimit'] @ClientNumLimit = params['ClientNumLimit'] @RequestId = params['RequestId'] end end # DescribeMQTTMessageList请求参数结构体 class DescribeMQTTMessageListRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param StartTime: 开始时间 # @type StartTime: Integer # @param EndTime: 结束时间 # @type EndTime: Integer # @param TaskRequestId: 请求任务id # @type TaskRequestId: String # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer attr_accessor :InstanceId, :Topic, :StartTime, :EndTime, :TaskRequestId, :Offset, :Limit def initialize(instanceid=nil, topic=nil, starttime=nil, endtime=nil, taskrequestid=nil, offset=nil, limit=nil) @InstanceId = instanceid @Topic = topic @StartTime = starttime @EndTime = endtime @TaskRequestId = taskrequestid @Offset = offset @Limit = limit end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @StartTime = params['StartTime'] @EndTime = params['EndTime'] @TaskRequestId = params['TaskRequestId'] @Offset = params['Offset'] @Limit = params['Limit'] end end # DescribeMQTTMessageList返回参数结构体 class DescribeMQTTMessageListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 消息记录列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Data: Array # @param TaskRequestId: 请求任务id # @type TaskRequestId: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :TaskRequestId, :RequestId def initialize(totalcount=nil, data=nil, taskrequestid=nil, requestid=nil) @TotalCount = totalcount @Data = data @TaskRequestId = taskrequestid @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| mqttmessageitem_tmp = MQTTMessageItem.new mqttmessageitem_tmp.deserialize(i) @Data << mqttmessageitem_tmp end end @TaskRequestId = params['TaskRequestId'] @RequestId = params['RequestId'] end end # DescribeMQTTMessage请求参数结构体 class DescribeMQTTMessageRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param MsgId: 消息ID # @type MsgId: String attr_accessor :InstanceId, :Topic, :MsgId def initialize(instanceid=nil, topic=nil, msgid=nil) @InstanceId = instanceid @Topic = topic @MsgId = msgid end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @MsgId = params['MsgId'] end end # DescribeMQTTMessage返回参数结构体 class DescribeMQTTMessageResponse < TencentCloud::Common::AbstractModel # @param Body: 消息体 # @type Body: String # @param Properties: 详情参数 # @type Properties: Array # @param ProduceTime: 生产时间 # @type ProduceTime: String # @param MessageId: 消息ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type MessageId: String # @param ProducerAddr: 生产者地址 # @type ProducerAddr: String # @param ShowTopicName: Topic # @type ShowTopicName: String # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Body, :Properties, :ProduceTime, :MessageId, :ProducerAddr, :ShowTopicName, :RequestId def initialize(body=nil, properties=nil, producetime=nil, messageid=nil, produceraddr=nil, showtopicname=nil, requestid=nil) @Body = body @Properties = properties @ProduceTime = producetime @MessageId = messageid @ProducerAddr = produceraddr @ShowTopicName = showtopicname @RequestId = requestid end def deserialize(params) @Body = params['Body'] unless params['Properties'].nil? @Properties = [] params['Properties'].each do |i| custommapentry_tmp = CustomMapEntry.new custommapentry_tmp.deserialize(i) @Properties << custommapentry_tmp end end @ProduceTime = params['ProduceTime'] @MessageId = params['MessageId'] @ProducerAddr = params['ProducerAddr'] @ShowTopicName = params['ShowTopicName'] @RequestId = params['RequestId'] end end # DescribeMQTTProductSKUList请求参数结构体 class DescribeMQTTProductSKUListRequest < TencentCloud::Common::AbstractModel def initialize() end def deserialize(params) end end # DescribeMQTTProductSKUList返回参数结构体 class DescribeMQTTProductSKUListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param MQTTProductSkuList: mqtt商品配置信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type MQTTProductSkuList: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :MQTTProductSkuList, :RequestId def initialize(totalcount=nil, mqttproductskulist=nil, requestid=nil) @TotalCount = totalcount @MQTTProductSkuList = mqttproductskulist @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['MQTTProductSkuList'].nil? @MQTTProductSkuList = [] params['MQTTProductSkuList'].each do |i| mqttproductskuitem_tmp = MQTTProductSkuItem.new mqttproductskuitem_tmp.deserialize(i) @MQTTProductSkuList << mqttproductskuitem_tmp end end @RequestId = params['RequestId'] end end # DescribeMQTTTopicList请求参数结构体 class DescribeMQTTTopicListRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Filters: 查询条件列表 # @type Filters: Array # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer attr_accessor :InstanceId, :Filters, :Offset, :Limit def initialize(instanceid=nil, filters=nil, offset=nil, limit=nil) @InstanceId = instanceid @Filters = filters @Offset = offset @Limit = limit end def deserialize(params) @InstanceId = params['InstanceId'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @Offset = params['Offset'] @Limit = params['Limit'] end end # DescribeMQTTTopicList返回参数结构体 class DescribeMQTTTopicListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 主题列表 # @type Data: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :RequestId def initialize(totalcount=nil, data=nil, requestid=nil) @TotalCount = totalcount @Data = data @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| mqtttopicitem_tmp = MQTTTopicItem.new mqtttopicitem_tmp.deserialize(i) @Data << mqtttopicitem_tmp end end @RequestId = params['RequestId'] end end # DescribeMQTTTopic请求参数结构体 class DescribeMQTTTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String attr_accessor :InstanceId, :Topic def initialize(instanceid=nil, topic=nil) @InstanceId = instanceid @Topic = topic end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] end end # DescribeMQTTTopic返回参数结构体 class DescribeMQTTTopicResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题名称 # @type Topic: String # @param Remark: 备注 # @type Remark: String # @param CreatedTime: 创建时间,秒为单位 # @type CreatedTime: Integer # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :Topic, :Remark, :CreatedTime, :RequestId def initialize(instanceid=nil, topic=nil, remark=nil, createdtime=nil, requestid=nil) @InstanceId = instanceid @Topic = topic @Remark = remark @CreatedTime = createdtime @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @Remark = params['Remark'] @CreatedTime = params['CreatedTime'] @RequestId = params['RequestId'] end end # DescribeMQTTUserList请求参数结构体 class DescribeMQTTUserListRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Filters: 查询条件列表 # @type Filters: Array # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer attr_accessor :InstanceId, :Filters, :Offset, :Limit def initialize(instanceid=nil, filters=nil, offset=nil, limit=nil) @InstanceId = instanceid @Filters = filters @Offset = offset @Limit = limit end def deserialize(params) @InstanceId = params['InstanceId'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @Offset = params['Offset'] @Limit = params['Limit'] end end # DescribeMQTTUserList返回参数结构体 class DescribeMQTTUserListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 角色信息列表 # @type Data: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :RequestId def initialize(totalcount=nil, data=nil, requestid=nil) @TotalCount = totalcount @Data = data @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| mqttuseritem_tmp = MQTTUserItem.new mqttuseritem_tmp.deserialize(i) @Data << mqttuseritem_tmp end end @RequestId = params['RequestId'] end end # DescribeRoleList请求参数结构体 class DescribeRoleListRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer # @param Filters: 查询条件列表 # @type Filters: Array attr_accessor :InstanceId, :Offset, :Limit, :Filters def initialize(instanceid=nil, offset=nil, limit=nil, filters=nil) @InstanceId = instanceid @Offset = offset @Limit = limit @Filters = filters end def deserialize(params) @InstanceId = params['InstanceId'] @Offset = params['Offset'] @Limit = params['Limit'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end end end # DescribeRoleList返回参数结构体 class DescribeRoleListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 角色信息列表 # @type Data: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :RequestId def initialize(totalcount=nil, data=nil, requestid=nil) @TotalCount = totalcount @Data = data @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| roleitem_tmp = RoleItem.new roleitem_tmp.deserialize(i) @Data << roleitem_tmp end end @RequestId = params['RequestId'] end end # DescribeTopicList请求参数结构体 class DescribeTopicListRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Filters: 查询条件列表 # @type Filters: Array # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer attr_accessor :InstanceId, :Filters, :Offset, :Limit def initialize(instanceid=nil, filters=nil, offset=nil, limit=nil) @InstanceId = instanceid @Filters = filters @Offset = offset @Limit = limit end def deserialize(params) @InstanceId = params['InstanceId'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @Offset = params['Offset'] @Limit = params['Limit'] end end # DescribeTopicList返回参数结构体 class DescribeTopicListResponse < TencentCloud::Common::AbstractModel # @param TotalCount: 查询总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TotalCount: Integer # @param Data: 主题列表 # @type Data: Array # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :TotalCount, :Data, :RequestId def initialize(totalcount=nil, data=nil, requestid=nil) @TotalCount = totalcount @Data = data @RequestId = requestid end def deserialize(params) @TotalCount = params['TotalCount'] unless params['Data'].nil? @Data = [] params['Data'].each do |i| topicitem_tmp = TopicItem.new topicitem_tmp.deserialize(i) @Data << topicitem_tmp end end @RequestId = params['RequestId'] end end # DescribeTopic请求参数结构体 class DescribeTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param Filters: 查询条件列表 # @type Filters: Array # @param Offset: 查询起始位置 # @type Offset: Integer # @param Limit: 查询结果限制数量 # @type Limit: Integer attr_accessor :InstanceId, :Topic, :Filters, :Offset, :Limit def initialize(instanceid=nil, topic=nil, filters=nil, offset=nil, limit=nil) @InstanceId = instanceid @Topic = topic @Filters = filters @Offset = offset @Limit = limit end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] unless params['Filters'].nil? @Filters = [] params['Filters'].each do |i| filter_tmp = Filter.new filter_tmp.deserialize(i) @Filters << filter_tmp end end @Offset = params['Offset'] @Limit = params['Limit'] end end # DescribeTopic返回参数结构体 class DescribeTopicResponse < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题名称 # @type Topic: String # @param TopicType: 主题类型 # UNSPECIFIED:未指定, # NORMAL:普通消息, # FIFO:顺序消息, # DELAY:延时消息, # TRANSACTION:事务消息 # @type TopicType: String # @param Remark: 备注 # @type Remark: String # @param CreatedTime: 创建时间,秒为单位 # @type CreatedTime: Integer # @param LastUpdateTime: 最后写入时间,秒为单位 # @type LastUpdateTime: Integer # @param SubscriptionCount: 订阅数量 # @type SubscriptionCount: Integer # @param SubscriptionData: 订阅关系列表 # @type SubscriptionData: Array # @param MsgTTL: 消息保留时长 # @type MsgTTL: Integer # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :InstanceId, :Topic, :TopicType, :Remark, :CreatedTime, :LastUpdateTime, :SubscriptionCount, :SubscriptionData, :MsgTTL, :RequestId def initialize(instanceid=nil, topic=nil, topictype=nil, remark=nil, createdtime=nil, lastupdatetime=nil, subscriptioncount=nil, subscriptiondata=nil, msgttl=nil, requestid=nil) @InstanceId = instanceid @Topic = topic @TopicType = topictype @Remark = remark @CreatedTime = createdtime @LastUpdateTime = lastupdatetime @SubscriptionCount = subscriptioncount @SubscriptionData = subscriptiondata @MsgTTL = msgttl @RequestId = requestid end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @TopicType = params['TopicType'] @Remark = params['Remark'] @CreatedTime = params['CreatedTime'] @LastUpdateTime = params['LastUpdateTime'] @SubscriptionCount = params['SubscriptionCount'] unless params['SubscriptionData'].nil? @SubscriptionData = [] params['SubscriptionData'].each do |i| subscriptiondata_tmp = SubscriptionData.new subscriptiondata_tmp.deserialize(i) @SubscriptionData << subscriptiondata_tmp end end @MsgTTL = params['MsgTTL'] @RequestId = params['RequestId'] end end # DescribeTopicStatsOp请求参数结构体 class DescribeTopicStatsOpRequest < TencentCloud::Common::AbstractModel # @param Topic: 主题 # @type Topic: String attr_accessor :Topic def initialize(topic=nil) @Topic = topic end def deserialize(params) @Topic = params['Topic'] end end # DescribeTopicStatsOp返回参数结构体 class DescribeTopicStatsOpResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # 接入点信息 class Endpoint < TencentCloud::Common::AbstractModel # @param Type: 接入点类型,枚举值如下 # VPC: VPC; # PUBLIC: 公网; # INTERNAL: 支撑网; # @type Type: String # @param Status: 状态, # OPEN 开启, # CLOSE 关闭, # PROCESSING 操作中, # @type Status: String # @param PayMode: 付费类型,仅公网 # PREPAID 包年包月 # POSTPAID 按量付费 # 注意:此字段可能返回 null,表示取不到有效值。 # @type PayMode: String # @param EndpointUrl: 接入点地址 # 注意:此字段可能返回 null,表示取不到有效值。 # @type EndpointUrl: String # @param VpcId: VPC ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type VpcId: String # @param SubnetId: 子网ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type SubnetId: String # @param Bandwidth: 公网带宽,Mbps为单位 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Bandwidth: Integer # @param IpRules: 公网放通规则 # 注意:此字段可能返回 null,表示取不到有效值。 # @type IpRules: Array attr_accessor :Type, :Status, :PayMode, :EndpointUrl, :VpcId, :SubnetId, :Bandwidth, :IpRules def initialize(type=nil, status=nil, paymode=nil, endpointurl=nil, vpcid=nil, subnetid=nil, bandwidth=nil, iprules=nil) @Type = type @Status = status @PayMode = paymode @EndpointUrl = endpointurl @VpcId = vpcid @SubnetId = subnetid @Bandwidth = bandwidth @IpRules = iprules end def deserialize(params) @Type = params['Type'] @Status = params['Status'] @PayMode = params['PayMode'] @EndpointUrl = params['EndpointUrl'] @VpcId = params['VpcId'] @SubnetId = params['SubnetId'] @Bandwidth = params['Bandwidth'] unless params['IpRules'].nil? @IpRules = [] params['IpRules'].each do |i| iprule_tmp = IpRule.new iprule_tmp.deserialize(i) @IpRules << iprule_tmp end end end end # 查询过滤器 class Filter < TencentCloud::Common::AbstractModel # @param Name: 过滤条件名 # @type Name: String # @param Values: 过滤条件的值 # @type Values: Array attr_accessor :Name, :Values def initialize(name=nil, values=nil) @Name = name @Values = values end def deserialize(params) @Name = params['Name'] @Values = params['Values'] end end # ImportSourceClusterConsumerGroups请求参数结构体 class ImportSourceClusterConsumerGroupsRequest < TencentCloud::Common::AbstractModel # @param TaskId: 任务ID # @type TaskId: String # @param GroupList: 待导入的消费组列表 # @type GroupList: Array attr_accessor :TaskId, :GroupList def initialize(taskid=nil, grouplist=nil) @TaskId = taskid @GroupList = grouplist end def deserialize(params) @TaskId = params['TaskId'] unless params['GroupList'].nil? @GroupList = [] params['GroupList'].each do |i| sourceclustergroupconfig_tmp = SourceClusterGroupConfig.new sourceclustergroupconfig_tmp.deserialize(i) @GroupList << sourceclustergroupconfig_tmp end end end end # ImportSourceClusterConsumerGroups返回参数结构体 class ImportSourceClusterConsumerGroupsResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ImportSourceClusterTopics请求参数结构体 class ImportSourceClusterTopicsRequest < TencentCloud::Common::AbstractModel # @param TaskId: 任务ID # @type TaskId: String # @param TopicList: 待导入的主题列表 # @type TopicList: Array attr_accessor :TaskId, :TopicList def initialize(taskid=nil, topiclist=nil) @TaskId = taskid @TopicList = topiclist end def deserialize(params) @TaskId = params['TaskId'] unless params['TopicList'].nil? @TopicList = [] params['TopicList'].each do |i| sourceclustertopicconfig_tmp = SourceClusterTopicConfig.new sourceclustertopicconfig_tmp.deserialize(i) @TopicList << sourceclustertopicconfig_tmp end end end end # ImportSourceClusterTopics返回参数结构体 class ImportSourceClusterTopicsResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # 实例列表页中的实例信息 class InstanceItem < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param InstanceName: 实例名称 # @type InstanceName: String # @param Version: 实例版本 # @type Version: String # @param InstanceType: 实例类型, # EXPERIMENT,体验版 # BASIC,基础版 # PRO,专业版 # PLATINUM,铂金版 # @type InstanceType: String # @param InstanceStatus: 实例状态, # RUNNING, 运行中 # MAINTAINING,维护中 # ABNORMAL,异常 # OVERDUE,欠费 # DESTROYED,已删除 # CREATING,创建中 # MODIFYING,变配中 # CREATE_FAILURE,创建失败 # MODIFY_FAILURE,变配失败 # DELETING,删除中 # @type InstanceStatus: String # @param TopicNumLimit: 实例主题数上限 # @type TopicNumLimit: Integer # @param GroupNumLimit: 实例消费组数量上限 # @type GroupNumLimit: Integer # @param PayMode: 计费模式, # POSTPAID,按量计费 # PREPAID,包年包月 # @type PayMode: String # @param ExpiryTime: 到期时间,秒为单位 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ExpiryTime: Integer # @param Remark: 备注信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param TopicNum: 主题数量 # @type TopicNum: Integer # @param GroupNum: 消费组数量 # @type GroupNum: Integer # @param TagList: 标签列表 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TagList: Array # @param SkuCode: 商品规格 # @type SkuCode: String # @param TpsLimit: TPS限流值 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TpsLimit: Integer # @param ScaledTpsLimit: 弹性TPS限流值 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ScaledTpsLimit: Integer # @param MessageRetention: 消息保留时间,小时为单位 # 注意:此字段可能返回 null,表示取不到有效值。 # @type MessageRetention: Integer # @param MaxMessageDelay: 延迟消息最大时长,小时为单位 # 注意:此字段可能返回 null,表示取不到有效值。 # @type MaxMessageDelay: Integer attr_accessor :InstanceId, :InstanceName, :Version, :InstanceType, :InstanceStatus, :TopicNumLimit, :GroupNumLimit, :PayMode, :ExpiryTime, :Remark, :TopicNum, :GroupNum, :TagList, :SkuCode, :TpsLimit, :ScaledTpsLimit, :MessageRetention, :MaxMessageDelay def initialize(instanceid=nil, instancename=nil, version=nil, instancetype=nil, instancestatus=nil, topicnumlimit=nil, groupnumlimit=nil, paymode=nil, expirytime=nil, remark=nil, topicnum=nil, groupnum=nil, taglist=nil, skucode=nil, tpslimit=nil, scaledtpslimit=nil, messageretention=nil, maxmessagedelay=nil) @InstanceId = instanceid @InstanceName = instancename @Version = version @InstanceType = instancetype @InstanceStatus = instancestatus @TopicNumLimit = topicnumlimit @GroupNumLimit = groupnumlimit @PayMode = paymode @ExpiryTime = expirytime @Remark = remark @TopicNum = topicnum @GroupNum = groupnum @TagList = taglist @SkuCode = skucode @TpsLimit = tpslimit @ScaledTpsLimit = scaledtpslimit @MessageRetention = messageretention @MaxMessageDelay = maxmessagedelay end def deserialize(params) @InstanceId = params['InstanceId'] @InstanceName = params['InstanceName'] @Version = params['Version'] @InstanceType = params['InstanceType'] @InstanceStatus = params['InstanceStatus'] @TopicNumLimit = params['TopicNumLimit'] @GroupNumLimit = params['GroupNumLimit'] @PayMode = params['PayMode'] @ExpiryTime = params['ExpiryTime'] @Remark = params['Remark'] @TopicNum = params['TopicNum'] @GroupNum = params['GroupNum'] unless params['TagList'].nil? @TagList = [] params['TagList'].each do |i| tag_tmp = Tag.new tag_tmp.deserialize(i) @TagList << tag_tmp end end @SkuCode = params['SkuCode'] @TpsLimit = params['TpsLimit'] @ScaledTpsLimit = params['ScaledTpsLimit'] @MessageRetention = params['MessageRetention'] @MaxMessageDelay = params['MaxMessageDelay'] end end # IP规则 class IpRule < TencentCloud::Common::AbstractModel # @param Ip: IP地址 # @type Ip: String # @param Allow: 是否允许放行 # @type Allow: Boolean # @param Remark: 备注信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String attr_accessor :Ip, :Allow, :Remark def initialize(ip=nil, allow=nil, remark=nil) @Ip = ip @Allow = allow @Remark = remark end def deserialize(params) @Ip = params['Ip'] @Allow = params['Allow'] @Remark = params['Remark'] end end # MQTT 订阅关系 class MQTTClientSubscription < TencentCloud::Common::AbstractModel # @param TopicFilter: topic 订阅 # @type TopicFilter: String # @param Qos: 服务质量等级 # @type Qos: Integer attr_accessor :TopicFilter, :Qos def initialize(topicfilter=nil, qos=nil) @TopicFilter = topicfilter @Qos = qos end def deserialize(params) @TopicFilter = params['TopicFilter'] @Qos = params['Qos'] end end # MQTTEndpoint class MQTTEndpointItem < TencentCloud::Common::AbstractModel # @param Type: 类型 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Type: String # @param Url: 接入点 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Url: String # @param VpcId: vpc信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type VpcId: String # @param SubnetId: 子网信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type SubnetId: String # @param Host: 主机 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Host: String # @param Port: 端口 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Port: Integer attr_accessor :Type, :Url, :VpcId, :SubnetId, :Host, :Port def initialize(type=nil, url=nil, vpcid=nil, subnetid=nil, host=nil, port=nil) @Type = type @Url = url @VpcId = vpcid @SubnetId = subnetid @Host = host @Port = port end def deserialize(params) @Type = params['Type'] @Url = params['Url'] @VpcId = params['VpcId'] @SubnetId = params['SubnetId'] @Host = params['Host'] @Port = params['Port'] end end # MQTT 实例信息 class MQTTInstanceItem < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param InstanceName: 实例名称 # @type InstanceName: String # @param Version: 实例版本 # @type Version: String # @param InstanceType: 实例类型, # EXPERIMENT,体验版 # BASIC,基础版 # PRO,专业版 # PLATINUM,铂金版 # @type InstanceType: String # @param InstanceStatus: 实例状态, # RUNNING, 运行中 # MAINTAINING,维护中 # ABNORMAL,异常 # OVERDUE,欠费 # DESTROYED,已删除 # CREATING,创建中 # MODIFYING,变配中 # CREATE_FAILURE,创建失败 # MODIFY_FAILURE,变配失败 # DELETING,删除中 # @type InstanceStatus: String # @param TopicNumLimit: 实例主题数上限 # @type TopicNumLimit: Integer # @param Remark: 备注信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param TopicNum: 主题数量 # @type TopicNum: Integer # @param SkuCode: 商品规格 # @type SkuCode: String # @param TpsLimit: 弹性TPS限流值 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TpsLimit: Integer # @param CreateTime: 创建时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type CreateTime: Integer # @param SubscriptionNumLimit: 订阅关系上限 # 注意:此字段可能返回 null,表示取不到有效值。 # @type SubscriptionNumLimit: Integer # @param ClientNumLimit: 客户端连接数上线 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClientNumLimit: Integer attr_accessor :InstanceId, :InstanceName, :Version, :InstanceType, :InstanceStatus, :TopicNumLimit, :Remark, :TopicNum, :SkuCode, :TpsLimit, :CreateTime, :SubscriptionNumLimit, :ClientNumLimit def initialize(instanceid=nil, instancename=nil, version=nil, instancetype=nil, instancestatus=nil, topicnumlimit=nil, remark=nil, topicnum=nil, skucode=nil, tpslimit=nil, createtime=nil, subscriptionnumlimit=nil, clientnumlimit=nil) @InstanceId = instanceid @InstanceName = instancename @Version = version @InstanceType = instancetype @InstanceStatus = instancestatus @TopicNumLimit = topicnumlimit @Remark = remark @TopicNum = topicnum @SkuCode = skucode @TpsLimit = tpslimit @CreateTime = createtime @SubscriptionNumLimit = subscriptionnumlimit @ClientNumLimit = clientnumlimit end def deserialize(params) @InstanceId = params['InstanceId'] @InstanceName = params['InstanceName'] @Version = params['Version'] @InstanceType = params['InstanceType'] @InstanceStatus = params['InstanceStatus'] @TopicNumLimit = params['TopicNumLimit'] @Remark = params['Remark'] @TopicNum = params['TopicNum'] @SkuCode = params['SkuCode'] @TpsLimit = params['TpsLimit'] @CreateTime = params['CreateTime'] @SubscriptionNumLimit = params['SubscriptionNumLimit'] @ClientNumLimit = params['ClientNumLimit'] end end # 消息记录 class MQTTMessageItem < TencentCloud::Common::AbstractModel # @param MsgId: 消息ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type MsgId: String # @param Tags: 消息tag # 注意:此字段可能返回 null,表示取不到有效值。 # @type Tags: String # @param Keys: 消息key # 注意:此字段可能返回 null,表示取不到有效值。 # @type Keys: String # @param ProducerAddr: 客户端地址 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ProducerAddr: String # @param ProduceTime: 消息发送时间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ProduceTime: String # @param DeadLetterResendTimes: 死信重发次数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type DeadLetterResendTimes: Integer # @param DeadLetterResendSuccessTimes: 死信重发成功次数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type DeadLetterResendSuccessTimes: Integer # @param SubTopic: 子topic # 注意:此字段可能返回 null,表示取不到有效值。 # @type SubTopic: String # @param Qos: 消息质量等级 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Qos: String attr_accessor :MsgId, :Tags, :Keys, :ProducerAddr, :ProduceTime, :DeadLetterResendTimes, :DeadLetterResendSuccessTimes, :SubTopic, :Qos def initialize(msgid=nil, tags=nil, keys=nil, produceraddr=nil, producetime=nil, deadletterresendtimes=nil, deadletterresendsuccesstimes=nil, subtopic=nil, qos=nil) @MsgId = msgid @Tags = tags @Keys = keys @ProducerAddr = produceraddr @ProduceTime = producetime @DeadLetterResendTimes = deadletterresendtimes @DeadLetterResendSuccessTimes = deadletterresendsuccesstimes @SubTopic = subtopic @Qos = qos end def deserialize(params) @MsgId = params['MsgId'] @Tags = params['Tags'] @Keys = params['Keys'] @ProducerAddr = params['ProducerAddr'] @ProduceTime = params['ProduceTime'] @DeadLetterResendTimes = params['DeadLetterResendTimes'] @DeadLetterResendSuccessTimes = params['DeadLetterResendSuccessTimes'] @SubTopic = params['SubTopic'] @Qos = params['Qos'] end end # MQTT ProductSkuItem class MQTTProductSkuItem < TencentCloud::Common::AbstractModel # @param InstanceType: 类型 # 注意:此字段可能返回 null,表示取不到有效值。 # @type InstanceType: String # @param SkuCode: cide # 注意:此字段可能返回 null,表示取不到有效值。 # @type SkuCode: String # @param OnSale: sale # 注意:此字段可能返回 null,表示取不到有效值。 # @type OnSale: Boolean # @param TopicNumLimit: topic num限制 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicNumLimit: Integer # @param TpsLimit: tps # 注意:此字段可能返回 null,表示取不到有效值。 # @type TpsLimit: Integer # @param ClientNumLimit: 客户端连接数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClientNumLimit: Integer # @param SubscriptionNumLimit: 订阅数限制 # 注意:此字段可能返回 null,表示取不到有效值。 # @type SubscriptionNumLimit: Integer # @param ProxySpecCore: 代理核 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ProxySpecCore: Integer # @param ProxySpecMemory: 代理内存 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ProxySpecMemory: Integer # @param ProxySpecCount: 代理总数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ProxySpecCount: Integer attr_accessor :InstanceType, :SkuCode, :OnSale, :TopicNumLimit, :TpsLimit, :ClientNumLimit, :SubscriptionNumLimit, :ProxySpecCore, :ProxySpecMemory, :ProxySpecCount def initialize(instancetype=nil, skucode=nil, onsale=nil, topicnumlimit=nil, tpslimit=nil, clientnumlimit=nil, subscriptionnumlimit=nil, proxyspeccore=nil, proxyspecmemory=nil, proxyspeccount=nil) @InstanceType = instancetype @SkuCode = skucode @OnSale = onsale @TopicNumLimit = topicnumlimit @TpsLimit = tpslimit @ClientNumLimit = clientnumlimit @SubscriptionNumLimit = subscriptionnumlimit @ProxySpecCore = proxyspeccore @ProxySpecMemory = proxyspecmemory @ProxySpecCount = proxyspeccount end def deserialize(params) @InstanceType = params['InstanceType'] @SkuCode = params['SkuCode'] @OnSale = params['OnSale'] @TopicNumLimit = params['TopicNumLimit'] @TpsLimit = params['TpsLimit'] @ClientNumLimit = params['ClientNumLimit'] @SubscriptionNumLimit = params['SubscriptionNumLimit'] @ProxySpecCore = params['ProxySpecCore'] @ProxySpecMemory = params['ProxySpecMemory'] @ProxySpecCount = params['ProxySpecCount'] end end # MQTT 主题详情 class MQTTTopicItem < TencentCloud::Common::AbstractModel # @param InstanceId: 实例 ID # @type InstanceId: String # @param Topic: 主题名称 # @type Topic: String # @param Remark: 主题描述 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String attr_accessor :InstanceId, :Topic, :Remark def initialize(instanceid=nil, topic=nil, remark=nil) @InstanceId = instanceid @Topic = topic @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @Remark = params['Remark'] end end # MQTT集群用户信息 class MQTTUserItem < TencentCloud::Common::AbstractModel # @param Username: 用户名 # @type Username: String # @param Password: 密码 # @type Password: String # @param PermRead: 是否开启消费 # @type PermRead: Boolean # @param PermWrite: 是否开启生产 # @type PermWrite: Boolean # @param Remark: 备注信息 # @type Remark: String # @param CreatedTime: 创建时间,秒为单位 # @type CreatedTime: Integer # @param ModifiedTime: 修改时间,秒为单位 # @type ModifiedTime: Integer attr_accessor :Username, :Password, :PermRead, :PermWrite, :Remark, :CreatedTime, :ModifiedTime def initialize(username=nil, password=nil, permread=nil, permwrite=nil, remark=nil, createdtime=nil, modifiedtime=nil) @Username = username @Password = password @PermRead = permread @PermWrite = permwrite @Remark = remark @CreatedTime = createdtime @ModifiedTime = modifiedtime end def deserialize(params) @Username = params['Username'] @Password = params['Password'] @PermRead = params['PermRead'] @PermWrite = params['PermWrite'] @Remark = params['Remark'] @CreatedTime = params['CreatedTime'] @ModifiedTime = params['ModifiedTime'] end end # ModifyConsumerGroup请求参数结构体 class ModifyConsumerGroupRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param ConsumerGroup: 消费组名称 # @type ConsumerGroup: String # @param ConsumeEnable: 是否开启消费 # @type ConsumeEnable: Boolean # @param ConsumeMessageOrderly: 顺序投递:true # 并发投递:false # @type ConsumeMessageOrderly: Boolean # @param MaxRetryTimes: 最大重试次数 # @type MaxRetryTimes: Integer # @param Remark: 备注 # @type Remark: String attr_accessor :InstanceId, :ConsumerGroup, :ConsumeEnable, :ConsumeMessageOrderly, :MaxRetryTimes, :Remark def initialize(instanceid=nil, consumergroup=nil, consumeenable=nil, consumemessageorderly=nil, maxretrytimes=nil, remark=nil) @InstanceId = instanceid @ConsumerGroup = consumergroup @ConsumeEnable = consumeenable @ConsumeMessageOrderly = consumemessageorderly @MaxRetryTimes = maxretrytimes @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @ConsumerGroup = params['ConsumerGroup'] @ConsumeEnable = params['ConsumeEnable'] @ConsumeMessageOrderly = params['ConsumeMessageOrderly'] @MaxRetryTimes = params['MaxRetryTimes'] @Remark = params['Remark'] end end # ModifyConsumerGroup返回参数结构体 class ModifyConsumerGroupResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyInstance请求参数结构体 class ModifyInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Name: 实例名称 # @type Name: String # @param Remark: 备注信息 # @type Remark: String # @param SendReceiveRatio: 消息发送和接收的比例 # @type SendReceiveRatio: Float # @param SkuCode: 调整实例规格的商品代号 # @type SkuCode: String # @param MessageRetention: 消息保留时长,小时为单位 # @type MessageRetention: Integer # @param ScaledTpsEnabled: 是否开启弹性TPS # @type ScaledTpsEnabled: Boolean # @param MaxTopicNum: 最大可创建主题数 # @type MaxTopicNum: Integer attr_accessor :InstanceId, :Name, :Remark, :SendReceiveRatio, :SkuCode, :MessageRetention, :ScaledTpsEnabled, :MaxTopicNum def initialize(instanceid=nil, name=nil, remark=nil, sendreceiveratio=nil, skucode=nil, messageretention=nil, scaledtpsenabled=nil, maxtopicnum=nil) @InstanceId = instanceid @Name = name @Remark = remark @SendReceiveRatio = sendreceiveratio @SkuCode = skucode @MessageRetention = messageretention @ScaledTpsEnabled = scaledtpsenabled @MaxTopicNum = maxtopicnum end def deserialize(params) @InstanceId = params['InstanceId'] @Name = params['Name'] @Remark = params['Remark'] @SendReceiveRatio = params['SendReceiveRatio'] @SkuCode = params['SkuCode'] @MessageRetention = params['MessageRetention'] @ScaledTpsEnabled = params['ScaledTpsEnabled'] @MaxTopicNum = params['MaxTopicNum'] end end # ModifyInstance返回参数结构体 class ModifyInstanceResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyMQTTInsPublicEndpoint请求参数结构体 class ModifyMQTTInsPublicEndpointRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Bandwidth: 带宽 # @type Bandwidth: Integer # @param Rules: 公网访问规则 # @type Rules: Array attr_accessor :InstanceId, :Bandwidth, :Rules def initialize(instanceid=nil, bandwidth=nil, rules=nil) @InstanceId = instanceid @Bandwidth = bandwidth @Rules = rules end def deserialize(params) @InstanceId = params['InstanceId'] @Bandwidth = params['Bandwidth'] unless params['Rules'].nil? @Rules = [] params['Rules'].each do |i| publicaccessrule_tmp = PublicAccessRule.new publicaccessrule_tmp.deserialize(i) @Rules << publicaccessrule_tmp end end end end # ModifyMQTTInsPublicEndpoint返回参数结构体 class ModifyMQTTInsPublicEndpointResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyMQTTInstanceCertBinding请求参数结构体 class ModifyMQTTInstanceCertBindingRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param SSLServerCertId: 服务端证书id # @type SSLServerCertId: String # @param SSLCaCertId: CA证书id # @type SSLCaCertId: String attr_accessor :InstanceId, :SSLServerCertId, :SSLCaCertId def initialize(instanceid=nil, sslservercertid=nil, sslcacertid=nil) @InstanceId = instanceid @SSLServerCertId = sslservercertid @SSLCaCertId = sslcacertid end def deserialize(params) @InstanceId = params['InstanceId'] @SSLServerCertId = params['SSLServerCertId'] @SSLCaCertId = params['SSLCaCertId'] end end # ModifyMQTTInstanceCertBinding返回参数结构体 class ModifyMQTTInstanceCertBindingResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyMQTTInstance请求参数结构体 class ModifyMQTTInstanceRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Name: 实例名称 # @type Name: String # @param Remark: 备注信息 # @type Remark: String attr_accessor :InstanceId, :Name, :Remark def initialize(instanceid=nil, name=nil, remark=nil) @InstanceId = instanceid @Name = name @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @Name = params['Name'] @Remark = params['Remark'] end end # ModifyMQTTInstance返回参数结构体 class ModifyMQTTInstanceResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyMQTTTopic请求参数结构体 class ModifyMQTTTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param Remark: 备注信息 # @type Remark: String attr_accessor :InstanceId, :Topic, :Remark def initialize(instanceid=nil, topic=nil, remark=nil) @InstanceId = instanceid @Topic = topic @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @Remark = params['Remark'] end end # ModifyMQTTTopic返回参数结构体 class ModifyMQTTTopicResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyMQTTUser请求参数结构体 class ModifyMQTTUserRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Username: 用户名 # @type Username: String # @param PermRead: 是否开启消费 # @type PermRead: Boolean # @param PermWrite: 是否开启生产 # @type PermWrite: Boolean # @param Remark: 备注 # @type Remark: String attr_accessor :InstanceId, :Username, :PermRead, :PermWrite, :Remark def initialize(instanceid=nil, username=nil, permread=nil, permwrite=nil, remark=nil) @InstanceId = instanceid @Username = username @PermRead = permread @PermWrite = permwrite @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @Username = params['Username'] @PermRead = params['PermRead'] @PermWrite = params['PermWrite'] @Remark = params['Remark'] end end # ModifyMQTTUser返回参数结构体 class ModifyMQTTUserResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyRole请求参数结构体 class ModifyRoleRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Role: 角色名称 # @type Role: String # @param PermRead: 是否开启消费 # @type PermRead: Boolean # @param PermWrite: 是否开启生产 # @type PermWrite: Boolean # @param Remark: 备注 # @type Remark: String attr_accessor :InstanceId, :Role, :PermRead, :PermWrite, :Remark def initialize(instanceid=nil, role=nil, permread=nil, permwrite=nil, remark=nil) @InstanceId = instanceid @Role = role @PermRead = permread @PermWrite = permwrite @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @Role = params['Role'] @PermRead = params['PermRead'] @PermWrite = params['PermWrite'] @Remark = params['Remark'] end end # ModifyRole返回参数结构体 class ModifyRoleResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # ModifyTopic请求参数结构体 class ModifyTopicRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题 # @type Topic: String # @param QueueNum: 队列数量 # @type QueueNum: Integer # @param Remark: 备注信息 # @type Remark: String attr_accessor :InstanceId, :Topic, :QueueNum, :Remark def initialize(instanceid=nil, topic=nil, queuenum=nil, remark=nil) @InstanceId = instanceid @Topic = topic @QueueNum = queuenum @Remark = remark end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @QueueNum = params['QueueNum'] @Remark = params['Remark'] end end # ModifyTopic返回参数结构体 class ModifyTopicResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID,由服务端生成,每次请求都会返回(若请求因其他原因未能抵达服务端,则该次请求不会获得 RequestId)。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @RequestId = params['RequestId'] end end # 公网访问安全规则 class PublicAccessRule < TencentCloud::Common::AbstractModel # @param IpRule: ip网段信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type IpRule: String # @param Allow: 允许或者拒绝 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Allow: Boolean # @param Remark: 备注信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String attr_accessor :IpRule, :Allow, :Remark def initialize(iprule=nil, allow=nil, remark=nil) @IpRule = iprule @Allow = allow @Remark = remark end def deserialize(params) @IpRule = params['IpRule'] @Allow = params['Allow'] @Remark = params['Remark'] end end # 角色信息 class RoleItem < TencentCloud::Common::AbstractModel # @param RoleName: 角色名称 # @type RoleName: String # @param AccessKey: Access Key # @type AccessKey: String # @param SecretKey: Secret Key # @type SecretKey: String # @param PermRead: 是否开启消费 # @type PermRead: Boolean # @param PermWrite: 是否开启生产 # @type PermWrite: Boolean # @param Remark: 备注信息 # @type Remark: String # @param CreatedTime: 创建时间,秒为单位 # @type CreatedTime: Integer # @param ModifiedTime: 修改时间,秒为单位 # @type ModifiedTime: Integer attr_accessor :RoleName, :AccessKey, :SecretKey, :PermRead, :PermWrite, :Remark, :CreatedTime, :ModifiedTime def initialize(rolename=nil, accesskey=nil, secretkey=nil, permread=nil, permwrite=nil, remark=nil, createdtime=nil, modifiedtime=nil) @RoleName = rolename @AccessKey = accesskey @SecretKey = secretkey @PermRead = permread @PermWrite = permwrite @Remark = remark @CreatedTime = createdtime @ModifiedTime = modifiedtime end def deserialize(params) @RoleName = params['RoleName'] @AccessKey = params['AccessKey'] @SecretKey = params['SecretKey'] @PermRead = params['PermRead'] @PermWrite = params['PermWrite'] @Remark = params['Remark'] @CreatedTime = params['CreatedTime'] @ModifiedTime = params['ModifiedTime'] end end # 消费组配置信息 class SourceClusterGroupConfig < TencentCloud::Common::AbstractModel # @param GroupName: 消费组名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type GroupName: String # @param Remark: 备注信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param Imported: 是否已导入,作为入参时无效 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Imported: Boolean # @param Namespace: 命名空间,仅4.x集群有效 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Namespace: String # @param ImportStatus: 导入状态 # Unknown 未知 # Success 成功 # Failure 失败 # AlreadyExists 已存在 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ImportStatus: String attr_accessor :GroupName, :Remark, :Imported, :Namespace, :ImportStatus def initialize(groupname=nil, remark=nil, imported=nil, namespace=nil, importstatus=nil) @GroupName = groupname @Remark = remark @Imported = imported @Namespace = namespace @ImportStatus = importstatus end def deserialize(params) @GroupName = params['GroupName'] @Remark = params['Remark'] @Imported = params['Imported'] @Namespace = params['Namespace'] @ImportStatus = params['ImportStatus'] end end # 源集群主题配置 class SourceClusterTopicConfig < TencentCloud::Common::AbstractModel # @param TopicName: 主题名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicName: String # @param TopicType: 主题类型, # 5.x版本 # UNSPECIFIED 未指定 # NORMAL 普通消息 # FIFO 顺序消息 # DELAY 延迟消息 # TRANSACTION 事务消息 # 4.x版本 # Normal 普通消息 # PartitionedOrder 分区顺序消息 # Transaction 事务消息 # DelayScheduled 延时消息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicType: String # @param QueueNum: 队列数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type QueueNum: Integer # @param Remark: 备注信息 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param Imported: 是否已导入,作为入参时无效 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Imported: Boolean # @param Namespace: 命名空间,仅4.x集群有效 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Namespace: String # @param ImportStatus: 导入状态, # Unknown 未知, # AlreadyExists 已存在, # Success 成功, # Failure 失败 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ImportStatus: String attr_accessor :TopicName, :TopicType, :QueueNum, :Remark, :Imported, :Namespace, :ImportStatus def initialize(topicname=nil, topictype=nil, queuenum=nil, remark=nil, imported=nil, namespace=nil, importstatus=nil) @TopicName = topicname @TopicType = topictype @QueueNum = queuenum @Remark = remark @Imported = imported @Namespace = namespace @ImportStatus = importstatus end def deserialize(params) @TopicName = params['TopicName'] @TopicType = params['TopicType'] @QueueNum = params['QueueNum'] @Remark = params['Remark'] @Imported = params['Imported'] @Namespace = params['Namespace'] @ImportStatus = params['ImportStatus'] end end # 主题与消费组的订阅关系数据 class SubscriptionData < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # 注意:此字段可能返回 null,表示取不到有效值。 # @type InstanceId: String # @param Topic: 主题名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Topic: String # @param TopicType: 主题类型 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicType: String # @param TopicQueueNum: 单个节点上主题队列数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicQueueNum: Integer # @param ConsumerGroup: 消费组名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ConsumerGroup: String # @param IsOnline: 是否在线 # 注意:此字段可能返回 null,表示取不到有效值。 # @type IsOnline: Boolean # @param ConsumeType: 消费类型 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ConsumeType: String # @param SubString: 订阅规则 # 注意:此字段可能返回 null,表示取不到有效值。 # @type SubString: String # @param ExpressionType: 过滤类型 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ExpressionType: String # @param Consistency: 订阅一致性 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Consistency: Integer # @param ConsumerLag: 消费堆积 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ConsumerLag: Integer # @param LastUpdateTime: 最后消费进度更新时间,秒为单位 # 注意:此字段可能返回 null,表示取不到有效值。 # @type LastUpdateTime: Integer # @param MaxRetryTimes: 最大重试次数 # 注意:此字段可能返回 null,表示取不到有效值。 # @type MaxRetryTimes: Integer # @param ConsumeMessageOrderly: 是否顺序消费 # 注意:此字段可能返回 null,表示取不到有效值。 # @type ConsumeMessageOrderly: Boolean # @param MessageModel: 消费模式: # BROADCASTING 广播模式; # CLUSTERING 集群模式; # 注意:此字段可能返回 null,表示取不到有效值。 # @type MessageModel: String attr_accessor :InstanceId, :Topic, :TopicType, :TopicQueueNum, :ConsumerGroup, :IsOnline, :ConsumeType, :SubString, :ExpressionType, :Consistency, :ConsumerLag, :LastUpdateTime, :MaxRetryTimes, :ConsumeMessageOrderly, :MessageModel def initialize(instanceid=nil, topic=nil, topictype=nil, topicqueuenum=nil, consumergroup=nil, isonline=nil, consumetype=nil, substring=nil, expressiontype=nil, consistency=nil, consumerlag=nil, lastupdatetime=nil, maxretrytimes=nil, consumemessageorderly=nil, messagemodel=nil) @InstanceId = instanceid @Topic = topic @TopicType = topictype @TopicQueueNum = topicqueuenum @ConsumerGroup = consumergroup @IsOnline = isonline @ConsumeType = consumetype @SubString = substring @ExpressionType = expressiontype @Consistency = consistency @ConsumerLag = consumerlag @LastUpdateTime = lastupdatetime @MaxRetryTimes = maxretrytimes @ConsumeMessageOrderly = consumemessageorderly @MessageModel = messagemodel end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @TopicType = params['TopicType'] @TopicQueueNum = params['TopicQueueNum'] @ConsumerGroup = params['ConsumerGroup'] @IsOnline = params['IsOnline'] @ConsumeType = params['ConsumeType'] @SubString = params['SubString'] @ExpressionType = params['ExpressionType'] @Consistency = params['Consistency'] @ConsumerLag = params['ConsumerLag'] @LastUpdateTime = params['LastUpdateTime'] @MaxRetryTimes = params['MaxRetryTimes'] @ConsumeMessageOrderly = params['ConsumeMessageOrderly'] @MessageModel = params['MessageModel'] end end # 标签数据 class Tag < TencentCloud::Common::AbstractModel # @param TagKey: 标签名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TagKey: String # @param TagValue: 标签值 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TagValue: String attr_accessor :TagKey, :TagValue def initialize(tagkey=nil, tagvalue=nil) @TagKey = tagkey @TagValue = tagvalue end def deserialize(params) @TagKey = params['TagKey'] @TagValue = params['TagValue'] end end # 标签过滤器 class TagFilter < TencentCloud::Common::AbstractModel # @param TagKey: 标签键名称 # @type TagKey: String # @param TagValues: 标签值列表 # @type TagValues: Array attr_accessor :TagKey, :TagValues def initialize(tagkey=nil, tagvalues=nil) @TagKey = tagkey @TagValues = tagvalues end def deserialize(params) @TagKey = params['TagKey'] @TagValues = params['TagValues'] end end # 列表上的主题信息 class TopicItem < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param Topic: 主题名称 # @type Topic: String # @param TopicType: 主题类型 # @type TopicType: String # @param QueueNum: 队列数量 # @type QueueNum: Integer # @param Remark: 描述 # 注意:此字段可能返回 null,表示取不到有效值。 # @type Remark: String # @param ClusterIdV4: 4.x的集群id # 注意:此字段可能返回 null,表示取不到有效值。 # @type ClusterIdV4: String # @param NamespaceV4: 4.x的命名空间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type NamespaceV4: String # @param TopicV4: 4.x的主题名称 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicV4: String # @param FullNamespaceV4: 4.x的完整命名空间 # 注意:此字段可能返回 null,表示取不到有效值。 # @type FullNamespaceV4: String # @param MsgTTL: 消息保留时长 # 注意:此字段可能返回 null,表示取不到有效值。 # @type MsgTTL: Integer attr_accessor :InstanceId, :Topic, :TopicType, :QueueNum, :Remark, :ClusterIdV4, :NamespaceV4, :TopicV4, :FullNamespaceV4, :MsgTTL def initialize(instanceid=nil, topic=nil, topictype=nil, queuenum=nil, remark=nil, clusteridv4=nil, namespacev4=nil, topicv4=nil, fullnamespacev4=nil, msgttl=nil) @InstanceId = instanceid @Topic = topic @TopicType = topictype @QueueNum = queuenum @Remark = remark @ClusterIdV4 = clusteridv4 @NamespaceV4 = namespacev4 @TopicV4 = topicv4 @FullNamespaceV4 = fullnamespacev4 @MsgTTL = msgttl end def deserialize(params) @InstanceId = params['InstanceId'] @Topic = params['Topic'] @TopicType = params['TopicType'] @QueueNum = params['QueueNum'] @Remark = params['Remark'] @ClusterIdV4 = params['ClusterIdV4'] @NamespaceV4 = params['NamespaceV4'] @TopicV4 = params['TopicV4'] @FullNamespaceV4 = params['FullNamespaceV4'] @MsgTTL = params['MsgTTL'] end end # VPC信息 class VpcInfo < TencentCloud::Common::AbstractModel # @param VpcId: VPC ID # @type VpcId: String # @param SubnetId: 子网ID # @type SubnetId: String attr_accessor :VpcId, :SubnetId def initialize(vpcid=nil, subnetid=nil) @VpcId = vpcid @SubnetId = subnetid end def deserialize(params) @VpcId = params['VpcId'] @SubnetId = params['SubnetId'] end end end end end