lib/v20190819/models.rb in tencentcloud-sdk-ckafka-1.0.273 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-1.0.274

@@ -3634,10 +3634,32 @@
             end
           end
         end
       end
 
+      # 实例 / topic 维度限流策略
+      class InstanceQuotaConfigResp < TencentCloud::Common::AbstractModel
+        # @param QuotaProducerByteRate: 生产限流大小，单位 MB/s
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type QuotaProducerByteRate: Integer
+        # @param QuotaConsumerByteRate: 消费限流大小，单位 MB/s
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type QuotaConsumerByteRate: Integer
+
+        attr_accessor :QuotaProducerByteRate, :QuotaConsumerByteRate
+        
+        def initialize(quotaproducerbyterate=nil, quotaconsumerbyterate=nil)
+          @QuotaProducerByteRate = quotaproducerbyterate
+          @QuotaConsumerByteRate = quotaconsumerbyterate
+        end
+
+        def deserialize(params)
+          @QuotaProducerByteRate = params['QuotaProducerByteRate']
+          @QuotaConsumerByteRate = params['QuotaConsumerByteRate']
+        end
+      end
+
       # 聚合的实例状态返回结果
       class InstanceResponse < TencentCloud::Common::AbstractModel
         # @param InstanceList: 符合条件的实例列表
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type InstanceList: Array
@@ -3941,14 +3963,18 @@
         # @type AclRuleName: String
         # @param RetentionBytes: 可选, 保留文件大小. 默认为-1,单位bytes, 当前最小值为1048576B
         # @type RetentionBytes: Integer
         # @param Tags: 标签列表
         # @type Tags: Array
+        # @param QuotaProducerByteRate: 生产限流，单位 MB/s
+        # @type QuotaProducerByteRate: Integer
+        # @param QuotaConsumerByteRate: 消费限流，单位 MB/s
+        # @type QuotaConsumerByteRate: Integer
 
-        attr_accessor :InstanceId, :TopicName, :Note, :EnableWhiteList, :MinInsyncReplicas, :UncleanLeaderElectionEnable, :RetentionMs, :SegmentMs, :MaxMessageBytes, :CleanUpPolicy, :IpWhiteList, :EnableAclRule, :AclRuleName, :RetentionBytes, :Tags
+        attr_accessor :InstanceId, :TopicName, :Note, :EnableWhiteList, :MinInsyncReplicas, :UncleanLeaderElectionEnable, :RetentionMs, :SegmentMs, :MaxMessageBytes, :CleanUpPolicy, :IpWhiteList, :EnableAclRule, :AclRuleName, :RetentionBytes, :Tags, :QuotaProducerByteRate, :QuotaConsumerByteRate
         
-        def initialize(instanceid=nil, topicname=nil, note=nil, enablewhitelist=nil, mininsyncreplicas=nil, uncleanleaderelectionenable=nil, retentionms=nil, segmentms=nil, maxmessagebytes=nil, cleanuppolicy=nil, ipwhitelist=nil, enableaclrule=nil, aclrulename=nil, retentionbytes=nil, tags=nil)
+        def initialize(instanceid=nil, topicname=nil, note=nil, enablewhitelist=nil, mininsyncreplicas=nil, uncleanleaderelectionenable=nil, retentionms=nil, segmentms=nil, maxmessagebytes=nil, cleanuppolicy=nil, ipwhitelist=nil, enableaclrule=nil, aclrulename=nil, retentionbytes=nil, tags=nil, quotaproducerbyterate=nil, quotaconsumerbyterate=nil)
           @InstanceId = instanceid
           @TopicName = topicname
           @Note = note
           @EnableWhiteList = enablewhitelist
           @MinInsyncReplicas = mininsyncreplicas
@@ -3960,10 +3986,12 @@
           @IpWhiteList = ipwhitelist
           @EnableAclRule = enableaclrule
           @AclRuleName = aclrulename
           @RetentionBytes = retentionbytes
           @Tags = tags
+          @QuotaProducerByteRate = quotaproducerbyterate
+          @QuotaConsumerByteRate = quotaconsumerbyterate
         end
 
         def deserialize(params)
           @InstanceId = params['InstanceId']
           @TopicName = params['TopicName']
@@ -3985,10 +4013,12 @@
               tag_tmp = Tag.new
               tag_tmp.deserialize(i)
               @Tags << tag_tmp
             end
           end
+          @QuotaProducerByteRate = params['QuotaProducerByteRate']
+          @QuotaConsumerByteRate = params['QuotaConsumerByteRate']
         end
       end
 
       # ModifyTopicAttributes返回参数结构体
       class ModifyTopicAttributesResponse < TencentCloud::Common::AbstractModel
@@ -4420,24 +4450,28 @@
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type EnableAclRule: Integer
         # @param AclRuleList: 预设策略列表
         # 注意：此字段可能返回 null，表示取不到有效值。
         # @type AclRuleList: Array
+        # @param QuotaConfig: topic 限流策略
+        # 注意：此字段可能返回 null，表示取不到有效值。
+        # @type QuotaConfig: :class:`Tencentcloud::Ckafka.v20190819.models.InstanceQuotaConfigResp`
 
-        attr_accessor :TopicId, :CreateTime, :Note, :PartitionNum, :EnableWhiteList, :IpWhiteList, :Config, :Partitions, :EnableAclRule, :AclRuleList
+        attr_accessor :TopicId, :CreateTime, :Note, :PartitionNum, :EnableWhiteList, :IpWhiteList, :Config, :Partitions, :EnableAclRule, :AclRuleList, :QuotaConfig
         
-        def initialize(topicid=nil, createtime=nil, note=nil, partitionnum=nil, enablewhitelist=nil, ipwhitelist=nil, config=nil, partitions=nil, enableaclrule=nil, aclrulelist=nil)
+        def initialize(topicid=nil, createtime=nil, note=nil, partitionnum=nil, enablewhitelist=nil, ipwhitelist=nil, config=nil, partitions=nil, enableaclrule=nil, aclrulelist=nil, quotaconfig=nil)
           @TopicId = topicid
           @CreateTime = createtime
           @Note = note
           @PartitionNum = partitionnum
           @EnableWhiteList = enablewhitelist
           @IpWhiteList = ipwhitelist
           @Config = config
           @Partitions = partitions
           @EnableAclRule = enableaclrule
           @AclRuleList = aclrulelist
+          @QuotaConfig = quotaconfig
         end
 
         def deserialize(params)
           @TopicId = params['TopicId']
           @CreateTime = params['CreateTime']
@@ -4463,9 +4497,13 @@
             params['AclRuleList'].each do |i|
               aclrule_tmp = AclRule.new
               aclrule_tmp.deserialize(i)
               @AclRuleList << aclrule_tmp
             end
+          end
+          unless params['QuotaConfig'].nil?
+            @QuotaConfig = InstanceQuotaConfigResp.new
+            @QuotaConfig.deserialize(params['QuotaConfig'])
           end
         end
       end
 
       # 主题详情