lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.596 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.597

- old
+ new

@@ -630,10 +630,37 @@ @ReturnCode = params['ReturnCode'] @Message = params['Message'] end end + # 主题占用Broker磁盘大小 + class BrokerTopicData < TencentCloud::Common::AbstractModel + # @param TopicName: 主题名称 + # 注意:此字段可能返回 null,表示取不到有效值。 + # @type TopicName: String + # @param TopicId: 主题ID + # 注意:此字段可能返回 null,表示取不到有效值。 + # @type TopicId: String + # @param DataSize: 主题占用Broker 容量大小 + # 注意:此字段可能返回 null,表示取不到有效值。 + # @type DataSize: Integer + + attr_accessor :TopicName, :TopicId, :DataSize + + def initialize(topicname=nil, topicid=nil, datasize=nil) + @TopicName = topicname + @TopicId = topicid + @DataSize = datasize + end + + def deserialize(params) + @TopicName = params['TopicName'] + @TopicId = params['TopicId'] + @DataSize = params['DataSize'] + end + end + # CancelAuthorizationToken请求参数结构体 class CancelAuthorizationTokenRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例ID # @type InstanceId: String # @param User: 用户 @@ -5336,25 +5363,29 @@ # @type RankingType: String # @param BeginDate: 排行起始日期 # @type BeginDate: String # @param EndDate: 排行结束日期 # @type EndDate: String + # @param BrokerIp: Broker IP 地址 + # @type BrokerIp: String - attr_accessor :InstanceId, :RankingType, :BeginDate, :EndDate + attr_accessor :InstanceId, :RankingType, :BeginDate, :EndDate, :BrokerIp - def initialize(instanceid=nil, rankingtype=nil, begindate=nil, enddate=nil) + def initialize(instanceid=nil, rankingtype=nil, begindate=nil, enddate=nil, brokerip=nil) @InstanceId = instanceid @RankingType = rankingtype @BeginDate = begindate @EndDate = enddate + @BrokerIp = brokerip end def deserialize(params) @InstanceId = params['InstanceId'] @RankingType = params['RankingType'] @BeginDate = params['BeginDate'] @EndDate = params['EndDate'] + @BrokerIp = params['BrokerIp'] end end # DescribeTopicFlowRanking返回参数结构体 class DescribeTopicFlowRankingResponse < TencentCloud::Common::AbstractModel @@ -10525,17 +10556,25 @@ # @param ConsumeSpeed: 消费者组消费速度排行速度 # @type ConsumeSpeed: Array # @param TopicMessageHeap: Topic 消息堆积/占用磁盘排行 # 注意:此字段可能返回 null,表示取不到有效值。 # @type TopicMessageHeap: Array + # @param BrokerIp: Broker Ip 列表 + # 注意:此字段可能返回 null,表示取不到有效值。 + # @type BrokerIp: Array + # @param BrokerTopicData: 单个broker 节点 Topic占用的数据大小 + # 注意:此字段可能返回 null,表示取不到有效值。 + # @type BrokerTopicData: Array - attr_accessor :TopicFlow, :ConsumeSpeed, :TopicMessageHeap + attr_accessor :TopicFlow, :ConsumeSpeed, :TopicMessageHeap, :BrokerIp, :BrokerTopicData - def initialize(topicflow=nil, consumespeed=nil, topicmessageheap=nil) + def initialize(topicflow=nil, consumespeed=nil, topicmessageheap=nil, brokerip=nil, brokertopicdata=nil) @TopicFlow = topicflow @ConsumeSpeed = consumespeed @TopicMessageHeap = topicmessageheap + @BrokerIp = brokerip + @BrokerTopicData = brokertopicdata end def deserialize(params) unless params['TopicFlow'].nil? @TopicFlow = [] @@ -10557,9 +10596,18 @@ @TopicMessageHeap = [] params['TopicMessageHeap'].each do |i| topicmessageheapranking_tmp = TopicMessageHeapRanking.new topicmessageheapranking_tmp.deserialize(i) @TopicMessageHeap << topicmessageheapranking_tmp + end + end + @BrokerIp = params['BrokerIp'] + unless params['BrokerTopicData'].nil? + @BrokerTopicData = [] + params['BrokerTopicData'].each do |i| + brokertopicdata_tmp = BrokerTopicData.new + brokertopicdata_tmp.deserialize(i) + @BrokerTopicData << brokertopicdata_tmp end end end end