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