lib/v20190819/models.rb in tencentcloud-sdk-ckafka-1.0.228 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-1.0.229
- old
+ new
@@ -2506,10 +2506,42 @@
end
@RequestId = params['RequestId']
end
end
+ # 动态硬盘扩容配置
+ class DynamicDiskConfig < TencentCloud::Common::AbstractModel
+ # @param Enable: 动态硬盘扩容配置开关（0: 关闭，1: 开启）
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type Enable: Integer
+ # @param StepForwardPercentage: 每次磁盘动态扩容大小百分比
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type StepForwardPercentage: Integer
+ # @param DiskQuotaPercentage: 磁盘配额百分比触发条件，即消息达到此值触发硬盘自动扩容事件
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type DiskQuotaPercentage: Integer
+ # @param MaxDiskSpace: 最大扩容硬盘大小，以 GB 为单位
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type MaxDiskSpace: Integer
+
+ attr_accessor :Enable, :StepForwardPercentage, :DiskQuotaPercentage, :MaxDiskSpace
+
+ def initialize(enable=nil, stepforwardpercentage=nil, diskquotapercentage=nil, maxdiskspace=nil)
+ @Enable = enable
+ @StepForwardPercentage = stepforwardpercentage
+ @DiskQuotaPercentage = diskquotapercentage
+ @MaxDiskSpace = maxdiskspace
+ end
+
+ def deserialize(params)
+ @Enable = params['Enable']
+ @StepForwardPercentage = params['StepForwardPercentage']
+ @DiskQuotaPercentage = params['DiskQuotaPercentage']
+ @MaxDiskSpace = params['MaxDiskSpace']
+ end
+ end
+
# 动态消息保留时间配置
class DynamicRetentionTime < TencentCloud::Common::AbstractModel
# @param Enable: 动态消息保留时间配置开关（0: 关闭，1: 开启）
# 注意：此字段可能返回 null，表示取不到有效值。
# @type Enable: Integer
@@ -2964,14 +2996,17 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type RemainingPartitions: Integer
# @param RemainingTopics: 剩余创建主题数
# 注意：此字段可能返回 null，表示取不到有效值。
# @type RemainingTopics: Integer
+ # @param DynamicDiskConfig: 动态硬盘扩容策略
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type DynamicDiskConfig: :class:`Tencentcloud::Ckafka.v20190819.models.DynamicDiskConfig`
- attr_accessor :InstanceId, :InstanceName, :VipList, :Vip, :Vport, :Status, :Bandwidth, :DiskSize, :ZoneId, :VpcId, :SubnetId, :Healthy, :HealthyMessage, :CreateTime, :MsgRetentionTime, :Config, :RemainderPartitions, :RemainderTopics, :CreatedPartitions, :CreatedTopics, :Tags, :ExpireTime, :ZoneIds, :Version, :MaxGroupNum, :Cvm, :InstanceType, :Features, :RetentionTimeConfig, :MaxConnection, :PublicNetwork, :DeleteRouteTimestamp, :RemainingPartitions, :RemainingTopics
+ attr_accessor :InstanceId, :InstanceName, :VipList, :Vip, :Vport, :Status, :Bandwidth, :DiskSize, :ZoneId, :VpcId, :SubnetId, :Healthy, :HealthyMessage, :CreateTime, :MsgRetentionTime, :Config, :RemainderPartitions, :RemainderTopics, :CreatedPartitions, :CreatedTopics, :Tags, :ExpireTime, :ZoneIds, :Version, :MaxGroupNum, :Cvm, :InstanceType, :Features, :RetentionTimeConfig, :MaxConnection, :PublicNetwork, :DeleteRouteTimestamp, :RemainingPartitions, :RemainingTopics, :DynamicDiskConfig
- def initialize(instanceid=nil, instancename=nil, viplist=nil, vip=nil, vport=nil, status=nil, bandwidth=nil, disksize=nil, zoneid=nil, vpcid=nil, subnetid=nil, healthy=nil, healthymessage=nil, createtime=nil, msgretentiontime=nil, config=nil, remainderpartitions=nil, remaindertopics=nil, createdpartitions=nil, createdtopics=nil, tags=nil, expiretime=nil, zoneids=nil, version=nil, maxgroupnum=nil, cvm=nil, instancetype=nil, features=nil, retentiontimeconfig=nil, maxconnection=nil, publicnetwork=nil, deleteroutetimestamp=nil, remainingpartitions=nil, remainingtopics=nil)
+ def initialize(instanceid=nil, instancename=nil, viplist=nil, vip=nil, vport=nil, status=nil, bandwidth=nil, disksize=nil, zoneid=nil, vpcid=nil, subnetid=nil, healthy=nil, healthymessage=nil, createtime=nil, msgretentiontime=nil, config=nil, remainderpartitions=nil, remaindertopics=nil, createdpartitions=nil, createdtopics=nil, tags=nil, expiretime=nil, zoneids=nil, version=nil, maxgroupnum=nil, cvm=nil, instancetype=nil, features=nil, retentiontimeconfig=nil, maxconnection=nil, publicnetwork=nil, deleteroutetimestamp=nil, remainingpartitions=nil, remainingtopics=nil, dynamicdiskconfig=nil)
@InstanceId = instanceid
@InstanceName = instancename
@VipList = viplist
@Vip = vip
@Vport = vport
@@ -3002,10 +3037,11 @@
@MaxConnection = maxconnection
@PublicNetwork = publicnetwork
@DeleteRouteTimestamp = deleteroutetimestamp
@RemainingPartitions = remainingpartitions
@RemainingTopics = remainingtopics
+ @DynamicDiskConfig = dynamicdiskconfig
end
def deserialize(params)
@InstanceId = params['InstanceId']
@InstanceName = params['InstanceName']
@@ -3059,10 +3095,14 @@
@MaxConnection = params['MaxConnection']
@PublicNetwork = params['PublicNetwork']
@DeleteRouteTimestamp = params['DeleteRouteTimestamp']
@RemainingPartitions = params['RemainingPartitions']
@RemainingTopics = params['RemainingTopics']
+ unless params['DynamicDiskConfig'].nil?
+ @DynamicDiskConfig = DynamicDiskConfig.new
+ @DynamicDiskConfig.deserialize(params['DynamicDiskConfig'])
+ end
end
end
# 实例配置实体
class InstanceConfigDO < TencentCloud::Common::AbstractModel
@@ -3419,21 +3459,24 @@
# @type DynamicRetentionConfig: :class:`Tencentcloud::Ckafka.v20190819.models.DynamicRetentionTime`
# @param RebalanceTime: 修改升配置rebalance时间
# @type RebalanceTime: Integer
# @param PublicNetwork: 时间戳
# @type PublicNetwork: Integer
+ # @param DynamicDiskConfig: 动态硬盘扩容策略配置
+ # @type DynamicDiskConfig: :class:`Tencentcloud::Ckafka.v20190819.models.DynamicDiskConfig`
- attr_accessor :InstanceId, :MsgRetentionTime, :InstanceName, :Config, :DynamicRetentionConfig, :RebalanceTime, :PublicNetwork
+ attr_accessor :InstanceId, :MsgRetentionTime, :InstanceName, :Config, :DynamicRetentionConfig, :RebalanceTime, :PublicNetwork, :DynamicDiskConfig
- def initialize(instanceid=nil, msgretentiontime=nil, instancename=nil, config=nil, dynamicretentionconfig=nil, rebalancetime=nil, publicnetwork=nil)
+ def initialize(instanceid=nil, msgretentiontime=nil, instancename=nil, config=nil, dynamicretentionconfig=nil, rebalancetime=nil, publicnetwork=nil, dynamicdiskconfig=nil)
@InstanceId = instanceid
@MsgRetentionTime = msgretentiontime
@InstanceName = instancename
@Config = config
@DynamicRetentionConfig = dynamicretentionconfig
@RebalanceTime = rebalancetime
@PublicNetwork = publicnetwork
+ @DynamicDiskConfig = dynamicdiskconfig
end
def deserialize(params)
@InstanceId = params['InstanceId']
@MsgRetentionTime = params['MsgRetentionTime']
@@ -3446,10 +3489,14 @@
@DynamicRetentionConfig = DynamicRetentionTime.new
@DynamicRetentionConfig.deserialize(params['DynamicRetentionConfig'])
end
@RebalanceTime = params['RebalanceTime']
@PublicNetwork = params['PublicNetwork']
+ unless params['DynamicDiskConfig'].nil?
+ @DynamicDiskConfig = DynamicDiskConfig.new
+ @DynamicDiskConfig.deserialize(params['DynamicDiskConfig'])
+ end
end
end
# ModifyInstanceAttributes返回参数结构体
class ModifyInstanceAttributesResponse < TencentCloud::Common::AbstractModel
@@ -3553,14 +3600,16 @@
# @type EnableAclRule: Integer
# @param AclRuleName: 预设ACL规则的名称
# @type AclRuleName: String
# @param RetentionBytes: 可选, 保留文件大小. 默认为-1,单位bytes, 当前最小值为1048576B
# @type RetentionBytes: Integer
+ # @param Tags: 标签列表
+ # @type Tags: Array
- attr_accessor :InstanceId, :TopicName, :Note, :EnableWhiteList, :MinInsyncReplicas, :UncleanLeaderElectionEnable, :RetentionMs, :SegmentMs, :MaxMessageBytes, :CleanUpPolicy, :IpWhiteList, :EnableAclRule, :AclRuleName, :RetentionBytes
+ attr_accessor :InstanceId, :TopicName, :Note, :EnableWhiteList, :MinInsyncReplicas, :UncleanLeaderElectionEnable, :RetentionMs, :SegmentMs, :MaxMessageBytes, :CleanUpPolicy, :IpWhiteList, :EnableAclRule, :AclRuleName, :RetentionBytes, :Tags
- 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)
+ 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)
@InstanceId = instanceid
@TopicName = topicname
@Note = note
@EnableWhiteList = enablewhitelist
@MinInsyncReplicas = mininsyncreplicas
@@ -3571,10 +3620,11 @@
@CleanUpPolicy = cleanuppolicy
@IpWhiteList = ipwhitelist
@EnableAclRule = enableaclrule
@AclRuleName = aclrulename
@RetentionBytes = retentionbytes
+ @Tags = tags
end
def deserialize(params)
@InstanceId = params['InstanceId']
@TopicName = params['TopicName']
@@ -3588,9 +3638,17 @@
@CleanUpPolicy = params['CleanUpPolicy']
@IpWhiteList = params['IpWhiteList']
@EnableAclRule = params['EnableAclRule']
@AclRuleName = params['AclRuleName']
@RetentionBytes = params['RetentionBytes']
+ unless params['Tags'].nil?
+ @Tags = []
+ params['Tags'].each do |i|
+ tag_tmp = Tag.new
+ tag_tmp.deserialize(i)
+ @Tags << tag_tmp
+ end
+ end
end
end
# ModifyTopicAttributes返回参数结构体
class ModifyTopicAttributesResponse < TencentCloud::Common::AbstractModel