lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.633 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.634
- old
+ new
@@ -2268,12 +2268,12 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DeleteRouteTimestamp: String
attr_accessor :ReturnCode, :ReturnMessage, :Data, :DeleteRouteTimestamp
extend Gem::Deprecate
- deprecate :DeleteRouteTimestamp, :none, 2023, 7
- deprecate :DeleteRouteTimestamp=, :none, 2023, 7
+ deprecate :DeleteRouteTimestamp, :none, 2023, 8
+ deprecate :DeleteRouteTimestamp=, :none, 2023, 8
def initialize(returncode=nil, returnmessage=nil, data=nil, deleteroutetimestamp=nil)
@ReturnCode = returncode
@ReturnMessage = returnmessage
@Data = data
@@ -6335,14 +6335,16 @@
# @type DropDlq: :class:`Tencentcloud::Ckafka.v20190819.models.FailureParam`
# @param RecordMappingList: 使用数据订阅格式导入 es 时，消息与 es 索引字段映射关系。不填默认为默认字段匹配
# @type RecordMappingList: Array
# @param DateField: 消息要映射为 es 索引中 @timestamp 的字段，如果当前配置为空，则使用消息的时间戳进行映射
# @type DateField: String
+ # @param RecordMappingMode: 用来区分当前索引映射，属于新建索引还是存量索引。"EXIST_MAPPING"：从存量索引中选择；"NEW_MAPPING"：新建索引
+ # @type RecordMappingMode: String
- attr_accessor :Resource, :Port, :UserName, :Password, :SelfBuilt, :ServiceVip, :UniqVpcId, :DropInvalidMessage, :Index, :DateFormat, :ContentKey, :DropInvalidJsonMessage, :DocumentIdField, :IndexType, :DropCls, :DatabasePrimaryKey, :DropDlq, :RecordMappingList, :DateField
+ attr_accessor :Resource, :Port, :UserName, :Password, :SelfBuilt, :ServiceVip, :UniqVpcId, :DropInvalidMessage, :Index, :DateFormat, :ContentKey, :DropInvalidJsonMessage, :DocumentIdField, :IndexType, :DropCls, :DatabasePrimaryKey, :DropDlq, :RecordMappingList, :DateField, :RecordMappingMode
- def initialize(resource=nil, port=nil, username=nil, password=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, dropinvalidmessage=nil, index=nil, dateformat=nil, contentkey=nil, dropinvalidjsonmessage=nil, documentidfield=nil, indextype=nil, dropcls=nil, databaseprimarykey=nil, dropdlq=nil, recordmappinglist=nil, datefield=nil)
+ def initialize(resource=nil, port=nil, username=nil, password=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, dropinvalidmessage=nil, index=nil, dateformat=nil, contentkey=nil, dropinvalidjsonmessage=nil, documentidfield=nil, indextype=nil, dropcls=nil, databaseprimarykey=nil, dropdlq=nil, recordmappinglist=nil, datefield=nil, recordmappingmode=nil)
@Resource = resource
@Port = port
@UserName = username
@Password = password
@SelfBuilt = selfbuilt
@@ -6358,10 +6360,11 @@
@DropCls = dropcls
@DatabasePrimaryKey = databaseprimarykey
@DropDlq = dropdlq
@RecordMappingList = recordmappinglist
@DateField = datefield
+ @RecordMappingMode = recordmappingmode
end
def deserialize(params)
@Resource = params['Resource']
@Port = params['Port']
@@ -6393,10 +6396,11 @@
esrecordmapping_tmp.deserialize(i)
@RecordMappingList << esrecordmapping_tmp
end
end
@DateField = params['DateField']
+ @RecordMappingMode = params['RecordMappingMode']
end
end
# 消息字段与 es 索引的映射关系
class EsRecordMapping < TencentCloud::Common::AbstractModel
@@ -7555,14 +7559,17 @@
# 注意：此字段可能返回 null，表示取不到有效值。
# @type RemainingTopics: Integer
# @param DynamicDiskConfig: 动态硬盘扩容策略
# 注意：此字段可能返回 null，表示取不到有效值。
# @type DynamicDiskConfig: :class:`Tencentcloud::Ckafka.v20190819.models.DynamicDiskConfig`
+ # @param InstanceChargeType: 实例计费类型
+ # 注意：此字段可能返回 null，表示取不到有效值。
+ # @type InstanceChargeType: String
- 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
+ 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, :InstanceChargeType
- 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)
+ 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, instancechargetype=nil)
@InstanceId = instanceid
@InstanceName = instancename
@VipList = viplist
@Vip = vip
@Vport = vport
@@ -7594,10 +7601,11 @@
@PublicNetwork = publicnetwork
@DeleteRouteTimestamp = deleteroutetimestamp
@RemainingPartitions = remainingpartitions
@RemainingTopics = remainingtopics
@DynamicDiskConfig = dynamicdiskconfig
+ @InstanceChargeType = instancechargetype
end
def deserialize(params)
@InstanceId = params['InstanceId']
@InstanceName = params['InstanceName']
@@ -7655,10 +7663,11 @@
@RemainingTopics = params['RemainingTopics']
unless params['DynamicDiskConfig'].nil?
@DynamicDiskConfig = DynamicDiskConfig.new
@DynamicDiskConfig.deserialize(params['DynamicDiskConfig'])
end
+ @InstanceChargeType = params['InstanceChargeType']
end
end
# 实例购买付费参数
class InstanceChargeParam < TencentCloud::Common::AbstractModel
@@ -9908,11 +9917,11 @@
@TimeSpan = params['TimeSpan']
end
end
# RenewCkafkaInstance接口出参bigDealIds
- class RenewCkafkaInstanceResponse < TencentCloud::Common::AbstractModel
+ class RenewCkafkaInstanceResp < TencentCloud::Common::AbstractModel
# @param BigDealId: 订单号
# 注意：此字段可能返回 null，表示取不到有效值。
# @type BigDealId: String
# @param DealName: 子订单号
# 注意：此字段可能返回 null，表示取不到有效值。
@@ -9926,9 +9935,32 @@
end
def deserialize(params)
@BigDealId = params['BigDealId']
@DealName = params['DealName']
+ end
+ end
+
+ # RenewCkafkaInstance返回参数结构体
+ class RenewCkafkaInstanceResponse < TencentCloud::Common::AbstractModel
+ # @param Result: 返回值
+ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.RenewCkafkaInstanceResp`
+ # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。
+ # @type RequestId: String
+
+ attr_accessor :Result, :RequestId
+
+ def initialize(result=nil, requestid=nil)
+ @Result = result
+ @RequestId = requestid
+ end
+
+ def deserialize(params)
+ unless params['Result'].nil?
+ @Result = RenewCkafkaInstanceResp.new
+ @Result.deserialize(params['Result'])
+ end
+ @RequestId = params['RequestId']
end
end
# 数据处理——Value处理参数——替换参数
class ReplaceParam < TencentCloud::Common::AbstractModel