Class: TencentCloud::Ckafka::V20190819::TopicFlowRankingResult

Inherits:

TencentCloud::Common::AbstractModel

• Object
• TencentCloud::Common::AbstractModel
• TencentCloud::Ckafka::V20190819::TopicFlowRankingResult

Defined in:

lib/v20190819/models.rb

Overview

topic 生产消息数据，消费者数据

Instance Attribute Summary

• #BrokerIp ⇒ Object
• #BrokerTopicData ⇒ Object
• #BrokerTopicFlowData ⇒ Object
• #ConsumeSpeed ⇒ Object
• #TopicFlow ⇒ Object
• #TopicMessageHeap ⇒ Object

Instance Method Summary

• #deserialize(params) ⇒ Object
• #initialize(topicflow = nil, consumespeed = nil, topicmessageheap = nil, brokerip = nil, brokertopicdata = nil, brokertopicflowdata = nil) ⇒ TopicFlowRankingResult constructor

  A new instance of TopicFlowRankingResult.

Constructor Details

#initialize(topicflow = nil, consumespeed = nil, topicmessageheap = nil, brokerip = nil, brokertopicdata = nil, brokertopicflowdata = nil) ⇒ TopicFlowRankingResult

Returns a new instance of TopicFlowRankingResult.

# File 'lib/v20190819/models.rb', line 11870

def initialize(topicflow=nil, consumespeed=nil, topicmessageheap=nil, brokerip=nil, brokertopicdata=nil, brokertopicflowdata=nil)
  @TopicFlow = topicflow
  @ConsumeSpeed = consumespeed
  @TopicMessageHeap = topicmessageheap
  @BrokerIp = brokerip
  @BrokerTopicData = brokertopicdata
  @BrokerTopicFlowData = brokertopicflowdata
end

Instance Attribute Details

#BrokerIp ⇒ Object

Parameters:

• TopicFlow: —

  Topic 流量数组

• ConsumeSpeed: —

  消费者组消费速度排行速度

• TopicMessageHeap: —

  Topic 消息堆积/占用磁盘排行

• BrokerIp: —

  Broker Ip 列表

• BrokerTopicData: —

  单个broker 节点 Topic占用的数据大小

• BrokerTopicFlowData: —

  单个Broker 节点Topic 流量的大小(单位MB)

# File 'lib/v20190819/models.rb', line 11868

def BrokerIp
  @BrokerIp
end

#BrokerTopicData ⇒ Object

Parameters:

• TopicFlow: —

  Topic 流量数组

• ConsumeSpeed: —

  消费者组消费速度排行速度

• TopicMessageHeap: —

  Topic 消息堆积/占用磁盘排行

• BrokerIp: —

  Broker Ip 列表

• BrokerTopicData: —

  单个broker 节点 Topic占用的数据大小

• BrokerTopicFlowData: —

  单个Broker 节点Topic 流量的大小(单位MB)

# File 'lib/v20190819/models.rb', line 11868

def BrokerTopicData
  @BrokerTopicData
end

#BrokerTopicFlowData ⇒ Object

Parameters:

• TopicFlow: —

  Topic 流量数组

• ConsumeSpeed: —

  消费者组消费速度排行速度

• TopicMessageHeap: —

  Topic 消息堆积/占用磁盘排行

• BrokerIp: —

  Broker Ip 列表

• BrokerTopicData: —

  单个broker 节点 Topic占用的数据大小

• BrokerTopicFlowData: —

  单个Broker 节点Topic 流量的大小(单位MB)

# File 'lib/v20190819/models.rb', line 11868

def BrokerTopicFlowData
  @BrokerTopicFlowData
end

#ConsumeSpeed ⇒ Object

Parameters:

• TopicFlow: —

  Topic 流量数组

• ConsumeSpeed: —

  消费者组消费速度排行速度

• TopicMessageHeap: —

  Topic 消息堆积/占用磁盘排行

• BrokerIp: —

  Broker Ip 列表

• BrokerTopicData: —

  单个broker 节点 Topic占用的数据大小

• BrokerTopicFlowData: —

  单个Broker 节点Topic 流量的大小(单位MB)

# File 'lib/v20190819/models.rb', line 11868

def ConsumeSpeed
  @ConsumeSpeed
end

#TopicFlow ⇒ Object

Parameters:

• TopicFlow: —

  Topic 流量数组

• ConsumeSpeed: —

  消费者组消费速度排行速度

• TopicMessageHeap: —

  Topic 消息堆积/占用磁盘排行

• BrokerIp: —

  Broker Ip 列表

• BrokerTopicData: —

  单个broker 节点 Topic占用的数据大小

• BrokerTopicFlowData: —

  单个Broker 节点Topic 流量的大小(单位MB)

# File 'lib/v20190819/models.rb', line 11868

def TopicFlow
  @TopicFlow
end

#TopicMessageHeap ⇒ Object

Parameters:

• TopicFlow: —

  Topic 流量数组

• ConsumeSpeed: —

  消费者组消费速度排行速度

• TopicMessageHeap: —

  Topic 消息堆积/占用磁盘排行

• BrokerIp: —

  Broker Ip 列表

• BrokerTopicData: —

  单个broker 节点 Topic占用的数据大小

• BrokerTopicFlowData: —

  单个Broker 节点Topic 流量的大小(单位MB)

# File 'lib/v20190819/models.rb', line 11868

def TopicMessageHeap
  @TopicMessageHeap
end

Instance Method Details

#deserialize(params) ⇒ Object

# File 'lib/v20190819/models.rb', line 11879

def deserialize(params)
  unless params['TopicFlow'].nil?
    @TopicFlow = []
    params['TopicFlow'].each do |i|
      topicflowranking_tmp = TopicFlowRanking.new
      topicflowranking_tmp.deserialize(i)
      @TopicFlow << topicflowranking_tmp
    end
  end
  unless params['ConsumeSpeed'].nil?
    @ConsumeSpeed = []
    params['ConsumeSpeed'].each do |i|
      consumergroupspeed_tmp = ConsumerGroupSpeed.new
      consumergroupspeed_tmp.deserialize(i)
      @ConsumeSpeed << consumergroupspeed_tmp
    end
  end
  unless params['TopicMessageHeap'].nil?
    @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
  unless params['BrokerTopicFlowData'].nil?
    @BrokerTopicFlowData = []
    params['BrokerTopicFlowData'].each do |i|
      brokertopicflowdata_tmp = BrokerTopicFlowData.new
      brokertopicflowdata_tmp.deserialize(i)
      @BrokerTopicFlowData << brokertopicflowdata_tmp
    end
  end
end