lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.590 vs lib/v20190819/models.rb in tencentcloud-sdk-ckafka-3.0.591

- old
+ new

@@ -33,11 +33,11 @@ # @type Operation: Integer # @param PermissionType: 权限类型(0:UNKNOWN，1:ANY，2:DENY，3:ALLOW) # @type PermissionType: Integer attr_accessor :ResourceType, :ResourceName, :Principal, :Host, :Operation, :PermissionType - + def initialize(resourcetype=nil, resourcename=nil, principal=nil, host=nil, operation=nil, permissiontype=nil) @ResourceType = resourcetype @ResourceName = resourcename @Principal = principal @Host = host @@ -62,11 +62,11 @@ # @param AclList: ACL列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type AclList: Array attr_accessor :TotalCount, :AclList - + def initialize(totalcount=nil, acllist=nil) @TotalCount = totalcount @AclList = acllist end @@ -124,11 +124,11 @@ # @param PatternTypeTitle: patternType的中文显示 # 注意：此字段可能返回 null，表示取不到有效值。 # @type PatternTypeTitle: String attr_accessor :RuleName, :InstanceId, :PatternType, :Pattern, :ResourceType, :AclList, :CreateTimeStamp, :IsApplied, :UpdateTimeStamp, :Comment, :TopicName, :TopicCount, :PatternTypeTitle - + def initialize(rulename=nil, instanceid=nil, patterntype=nil, pattern=nil, resourcetype=nil, acllist=nil, createtimestamp=nil, isapplied=nil, updatetimestamp=nil, comment=nil, topicname=nil, topiccount=nil, patterntypetitle=nil) @RuleName = rulename @InstanceId = instanceid @PatternType = patterntype @Pattern = pattern @@ -170,11 +170,11 @@ # @type Host: String # @param Principal: 用户列表，默认为User:*，表示任何user都可以访问，当前用户只能是用户列表中包含的用户。传入格式需要带【User:】前缀。例如用户A，传入为User:A。 # @type Principal: String attr_accessor :Operation, :PermissionType, :Host, :Principal - + def initialize(operation=nil, permissiontype=nil, host=nil, principal=nil) @Operation = operation @PermissionType = permissiontype @Host = host @Principal = principal @@ -195,11 +195,11 @@ # @param AclRuleList: AclRule列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type AclRuleList: Array attr_accessor :TotalCount, :AclRuleList - + def initialize(totalcount=nil, aclrulelist=nil) @TotalCount = totalcount @AclRuleList = aclrulelist end @@ -229,11 +229,11 @@ # @param InputValue: 需再次处理的KEY——KEY表达式 # 注意：此字段可能返回 null，表示取不到有效值。 # @type InputValue: String attr_accessor :Format, :Regex, :InputValueType, :InputValue - + def initialize(format=nil, regex=nil, inputvaluetype=nil, inputvalue=nil) @Format = format @Regex = regex @InputValueType = inputvaluetype @InputValue = inputvalue @@ -254,11 +254,11 @@ # @param AppIdList: 符合要求的App Id列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type AppIdList: Array attr_accessor :TotalCount, :AppIdList - + def initialize(totalcount=nil, appidlist=nil) @TotalCount = totalcount @AppIdList = appidlist end @@ -275,11 +275,11 @@ # @param Topics: topic信息列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Topics: Array attr_accessor :Version, :Topics - + def initialize(version=nil, topics=nil) @Version = version @Topics = topics end @@ -304,11 +304,11 @@ # @type User: String # @param Tokens: token串 # @type Tokens: String attr_accessor :InstanceId, :User, :Tokens - + def initialize(instanceid=nil, user=nil, tokens=nil) @InstanceId = instanceid @User = user @Tokens = tokens end @@ -327,11 +327,11 @@ # @type Result: Integer # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -346,11 +346,11 @@ # @param Format: ONE_BY_ONE单条输出，MERGE合并输出 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Format: String attr_accessor :Format - + def initialize(format=nil) @Format = format end def deserialize(params) @@ -364,11 +364,11 @@ # @type Body: String # @param Key: 发送消息的键名 # @type Key: String attr_accessor :Body, :Key - + def initialize(body=nil, key=nil) @Body = body @Key = key end @@ -388,11 +388,11 @@ # @type ResourceNames: Array # @param RuleList: 设置的ACL规则列表 # @type RuleList: Array attr_accessor :InstanceId, :ResourceType, :ResourceNames, :RuleList - + def initialize(instanceid=nil, resourcetype=nil, resourcenames=nil, rulelist=nil) @InstanceId = instanceid @ResourceType = resourcetype @ResourceNames = resourcenames @RuleList = rulelist @@ -419,11 +419,11 @@ # @type Result: Integer # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -443,11 +443,11 @@ # @type Partitions: Array # @param TopicName: 指定topic，默认所有topic # @type TopicName: Array attr_accessor :GroupName, :InstanceId, :Partitions, :TopicName - + def initialize(groupname=nil, instanceid=nil, partitions=nil, topicname=nil) @GroupName = groupname @InstanceId = instanceid @Partitions = partitions @TopicName = topicname @@ -474,11 +474,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -497,11 +497,11 @@ # @type InstanceId: String # @param Topic: 主题属性列表 # @type Topic: Array attr_accessor :InstanceId, :Topic - + def initialize(instanceid=nil, topic=nil) @InstanceId = instanceid @Topic = topic end @@ -524,11 +524,11 @@ # @type Result: Array # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -569,11 +569,11 @@ # @type SegmentMs: Integer # @param MaxMessageBytes: 批次的消息大小，范围1 KB到12 MB # @type MaxMessageBytes: Integer attr_accessor :TopicName, :PartitionNum, :Note, :ReplicaNum, :CleanUpPolicy, :MinInsyncReplicas, :UncleanLeaderElectionEnable, :RetentionMs, :RetentionBytes, :SegmentMs, :MaxMessageBytes - + def initialize(topicname=nil, partitionnum=nil, note=nil, replicanum=nil, cleanuppolicy=nil, mininsyncreplicas=nil, uncleanleaderelectionenable=nil, retentionms=nil, retentionbytes=nil, segmentms=nil, maxmessagebytes=nil) @TopicName = topicname @PartitionNum = partitionnum @Note = note @ReplicaNum = replicanum @@ -614,11 +614,11 @@ # @type ReturnCode: String # @param Message: 状态消息 # @type Message: String attr_accessor :InstanceId, :TopicName, :ReturnCode, :Message - + def initialize(instanceid=nil, topicname=nil, returncode=nil, message=nil) @InstanceId = instanceid @TopicName = topicname @ReturnCode = returncode @Message = message @@ -640,11 +640,11 @@ # @type User: String # @param Tokens: token串 # @type Tokens: String attr_accessor :InstanceId, :User, :Tokens - + def initialize(instanceid=nil, user=nil, tokens=nil) @InstanceId = instanceid @User = user @Tokens = tokens end @@ -663,11 +663,11 @@ # @type Result: Integer # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -682,11 +682,11 @@ # @param TaskId: 任务ID # 注意：此字段可能返回 null，表示取不到有效值。 # @type TaskId: Integer attr_accessor :TaskId - + def initialize(taskid=nil) @TaskId = taskid end def deserialize(params) @@ -698,11 +698,11 @@ class CheckCdcClusterRequest < TencentCloud::Common::AbstractModel # @param TaskId: 任务ID # @type TaskId: Integer attr_accessor :TaskId - + def initialize(taskid=nil) @TaskId = taskid end def deserialize(params) @@ -717,11 +717,11 @@ # @type Result: String # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -757,11 +757,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Port, :UserName, :Password, :Resource, :SelfBuilt, :ServiceVip, :UniqVpcId, :IsUpdate - + def initialize(port=nil, username=nil, password=nil, resource=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, isupdate=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -809,11 +809,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务，默认为true # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :SelfBuilt, :IsUpdate - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, selfbuilt=nil, isupdate=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -867,11 +867,11 @@ # @type Type: String # @param DropCls: 当设置成员参数DropInvalidMessageToCls设置为true时,DropInvalidMessage参数失效 # @type DropCls: :class:`Tencentcloud::Ckafka.v20190819.models.DropCls` attr_accessor :Cluster, :Database, :Table, :Schema, :Resource, :Ip, :Port, :UserName, :Password, :ServiceVip, :UniqVpcId, :SelfBuilt, :DropInvalidMessage, :Type, :DropCls - + def initialize(cluster=nil, database=nil, table=nil, schema=nil, resource=nil, ip=nil, port=nil, username=nil, password=nil, servicevip=nil, uniqvpcid=nil, selfbuilt=nil, dropinvalidmessage=nil, type=nil, dropcls=nil) @Cluster = cluster @Database = database @Table = table @Schema = schema @@ -927,11 +927,11 @@ # @type Type: String # @param AllowNull: 列项是否允许为空 # @type AllowNull: Boolean attr_accessor :ColumnName, :JsonKey, :Type, :AllowNull - + def initialize(columnname=nil, jsonkey=nil, type=nil, allownull=nil) @ColumnName = columnname @JsonKey = jsonkey @Type = type @AllowNull = allownull @@ -958,11 +958,11 @@ # @param TimeField: 指定消息中的某字段内容作为cls日志的时间。 # 字段内容格式需要是秒级时间戳 # @type TimeField: String attr_accessor :DecodeJson, :Resource, :LogSet, :ContentKey, :TimeField - + def initialize(decodejson=nil, resource=nil, logset=nil, contentkey=nil, timefield=nil) @DecodeJson = decodejson @Resource = resource @LogSet = logset @ContentKey = contentkey @@ -1002,11 +1002,11 @@ # @param ZoneIds: 集群节点所在的可用区，若该集群为跨可用区集群，则包含该集群节点所在的多个可用区。 # 注意：此字段可能返回 null，表示取不到有效值。 # @type ZoneIds: Array attr_accessor :ClusterId, :ClusterName, :MaxDiskSize, :MaxBandWidth, :AvailableDiskSize, :AvailableBandWidth, :ZoneId, :ZoneIds - + def initialize(clusterid=nil, clustername=nil, maxdisksize=nil, maxbandwidth=nil, availabledisksize=nil, availablebandwidth=nil, zoneid=nil, zoneids=nil) @ClusterId = clusterid @ClusterName = clustername @MaxDiskSize = maxdisksize @MaxBandWidth = maxbandwidth @@ -1055,11 +1055,11 @@ # @param RetentionBytes: 消息保留文件大小 # 注意：此字段可能返回 null，表示取不到有效值。 # @type RetentionBytes: Integer attr_accessor :Retention, :MinInsyncReplicas, :CleanUpPolicy, :SegmentMs, :UncleanLeaderElectionEnable, :SegmentBytes, :MaxMessageBytes, :RetentionBytes - + def initialize(retention=nil, mininsyncreplicas=nil, cleanuppolicy=nil, segmentms=nil, uncleanleaderelectionenable=nil, segmentbytes=nil, maxmessagebytes=nil, retentionbytes=nil) @Retention = retention @MinInsyncReplicas = mininsyncreplicas @CleanUpPolicy = cleanuppolicy @SegmentMs = segmentms @@ -1086,11 +1086,11 @@ # @param ResourceId: 连接源的Id # 注意：此字段可能返回 null，表示取不到有效值。 # @type ResourceId: String attr_accessor :ResourceId - + def initialize(resourceid=nil) @ResourceId = resourceid end def deserialize(params) @@ -1106,11 +1106,11 @@ # @type GroupId: String # @param TopicId: Topic的Id # @type TopicId: String attr_accessor :TopicName, :GroupId, :TopicId - + def initialize(topicname=nil, groupid=nil, topicid=nil) @TopicName = topicname @GroupId = groupid @TopicId = topicid end @@ -1128,11 +1128,11 @@ # @type ConsumerGroupName: String # @param SubscribedInfo: 订阅信息实体 # @type SubscribedInfo: Array attr_accessor :ConsumerGroupName, :SubscribedInfo - + def initialize(consumergroupname=nil, subscribedinfo=nil) @ConsumerGroupName = consumergroupname @SubscribedInfo = subscribedinfo end @@ -1174,11 +1174,11 @@ # @param GroupListForMonitor: 监控的组列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type GroupListForMonitor: Array attr_accessor :TotalCount, :TopicList, :GroupList, :TotalPartition, :PartitionListForMonitor, :TotalTopic, :TopicListForMonitor, :GroupListForMonitor - + def initialize(totalcount=nil, topiclist=nil, grouplist=nil, totalpartition=nil, partitionlistformonitor=nil, totaltopic=nil, topiclistformonitor=nil, grouplistformonitor=nil) @TotalCount = totalcount @TopicList = topiclist @GroupList = grouplist @TotalPartition = totalpartition @@ -1241,11 +1241,11 @@ # @type ConsumerGroupName: String # @param Speed: 消费速度 Count/Minute # @type Speed: Integer attr_accessor :ConsumerGroupName, :Speed - + def initialize(consumergroupname=nil, speed=nil) @ConsumerGroupName = consumergroupname @Speed = speed end @@ -1261,11 +1261,11 @@ # @type TopicId: String # @param TopicName: 主题名称 # @type TopicName: String attr_accessor :TopicId, :TopicName - + def initialize(topicid=nil, topicname=nil) @TopicId = topicid @TopicName = topicname end @@ -1295,11 +1295,11 @@ # @param Headers: 消息headers # 注意：此字段可能返回 null，表示取不到有效值。 # @type Headers: String attr_accessor :Topic, :Partition, :Offset, :Key, :Value, :Timestamp, :Headers - + def initialize(topic=nil, partition=nil, offset=nil, key=nil, value=nil, timestamp=nil, headers=nil) @Topic = topic @Partition = partition @Offset = offset @Key = key @@ -1337,11 +1337,11 @@ # @type ObjectKeyPrefix: String # @param DirectoryTimeFormat: 根据strptime 时间格式化的分区格式 # @type DirectoryTimeFormat: String attr_accessor :BucketName, :Region, :ObjectKey, :AggregateBatchSize, :AggregateInterval, :FormatOutputType, :ObjectKeyPrefix, :DirectoryTimeFormat - + def initialize(bucketname=nil, region=nil, objectkey=nil, aggregatebatchsize=nil, aggregateinterval=nil, formatoutputtype=nil, objectkeyprefix=nil, directorytimeformat=nil) @BucketName = bucketname @Region = region @ObjectKey = objectkey @AggregateBatchSize = aggregatebatchsize @@ -1381,11 +1381,11 @@ # @type Principal: String # @param ResourceNameList: 资源名称列表,Json字符串格式。ResourceName和resourceNameList只能指定其中一个。 # @type ResourceNameList: String attr_accessor :InstanceId, :ResourceType, :Operation, :PermissionType, :ResourceName, :Host, :Principal, :ResourceNameList - + def initialize(instanceid=nil, resourcetype=nil, operation=nil, permissiontype=nil, resourcename=nil, host=nil, principal=nil, resourcenamelist=nil) @InstanceId = instanceid @ResourceType = resourcetype @Operation = operation @PermissionType = permissiontype @@ -1413,11 +1413,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -1448,11 +1448,11 @@ # @type IsApplied: Integer # @param Comment: ACL规则的备注 # @type Comment: String attr_accessor :InstanceId, :ResourceType, :PatternType, :RuleName, :RuleList, :Pattern, :IsApplied, :Comment - + def initialize(instanceid=nil, resourcetype=nil, patterntype=nil, rulename=nil, rulelist=nil, pattern=nil, isapplied=nil, comment=nil) @InstanceId = instanceid @ResourceType = resourcetype @PatternType = patterntype @RuleName = rulename @@ -1487,11 +1487,11 @@ # @type Result: Integer # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -1519,11 +1519,11 @@ # @type DiskType: String # @param SystemDiskType: 系统盘类型 # @type SystemDiskType: String attr_accessor :CdcId, :CdcVpcId, :CdcSubnetId, :ZoneId, :Bandwidth, :DiskSize, :DiskType, :SystemDiskType - + def initialize(cdcid=nil, cdcvpcid=nil, cdcsubnetid=nil, zoneid=nil, bandwidth=nil, disksize=nil, disktype=nil, systemdisktype=nil) @CdcId = cdcid @CdcVpcId = cdcvpcid @CdcSubnetId = cdcsubnetid @ZoneId = zoneid @@ -1551,11 +1551,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.CdcClusterResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -1596,11 +1596,11 @@ # @type DorisConnectParam: :class:`Tencentcloud::Ckafka.v20190819.models.DorisConnectParam` # @param KafkaConnectParam: Kafka配置，Type为 KAFKA 时必填 # @type KafkaConnectParam: :class:`Tencentcloud::Ckafka.v20190819.models.KafkaConnectParam` attr_accessor :ResourceName, :Type, :Description, :DtsConnectParam, :MongoDBConnectParam, :EsConnectParam, :ClickHouseConnectParam, :MySQLConnectParam, :PostgreSQLConnectParam, :MariaDBConnectParam, :SQLServerConnectParam, :DorisConnectParam, :KafkaConnectParam - + def initialize(resourcename=nil, type=nil, description=nil, dtsconnectparam=nil, mongodbconnectparam=nil, esconnectparam=nil, clickhouseconnectparam=nil, mysqlconnectparam=nil, postgresqlconnectparam=nil, mariadbconnectparam=nil, sqlserverconnectparam=nil, dorisconnectparam=nil, kafkaconnectparam=nil) @ResourceName = resourcename @Type = type @Description = description @DtsConnectParam = dtsconnectparam @@ -1668,11 +1668,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.ConnectResourceResourceIdResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -1695,11 +1695,11 @@ # @type TopicName: String # @param TopicNameList: topic名称数组 # @type TopicNameList: Array attr_accessor :InstanceId, :GroupName, :TopicName, :TopicNameList - + def initialize(instanceid=nil, groupname=nil, topicname=nil, topicnamelist=nil) @InstanceId = instanceid @GroupName = groupname @TopicName = topicname @TopicNameList = topicnamelist @@ -1719,11 +1719,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -1758,11 +1758,11 @@ # @type TaskId: String # @param Tags: 标签列表 # @type Tags: Array attr_accessor :TaskName, :TaskType, :SourceResource, :TargetResource, :TransformParam, :PrivateLinkParam, :SchemaId, :TransformsParam, :TaskId, :Tags - + def initialize(taskname=nil, tasktype=nil, sourceresource=nil, targetresource=nil, transformparam=nil, privatelinkparam=nil, schemaid=nil, transformsparam=nil, taskid=nil, tags=nil) @TaskName = taskname @TaskType = tasktype @SourceResource = sourceresource @TargetResource = targetresource @@ -1817,11 +1817,11 @@ # @param DatahubId: 数据转储Id # 注意：此字段可能返回 null，表示取不到有效值。 # @type DatahubId: String attr_accessor :TaskId, :DatahubId - + def initialize(taskid=nil, datahubid=nil) @TaskId = taskid @DatahubId = datahubid end @@ -1837,11 +1837,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.CreateDatahubTaskRes` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -1866,11 +1866,11 @@ # @type Note: String # @param Tags: 标签列表 # @type Tags: Array attr_accessor :Name, :PartitionNum, :RetentionMs, :Note, :Tags - + def initialize(name=nil, partitionnum=nil, retentionms=nil, note=nil, tags=nil) @Name = name @PartitionNum = partitionnum @RetentionMs = retentionms @Note = note @@ -1899,11 +1899,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DatahubTopicResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -1954,11 +1954,11 @@ # @type InstanceNum: Integer # @param PublicNetworkMonthly: 公网带宽大小，单位 Mbps。默认是没有加上免费 3Mbps 带宽。例如总共需要 3Mbps 公网带宽，此处传 0；总共需要 4Mbps 公网带宽，此处传 1 # @type PublicNetworkMonthly: Integer attr_accessor :InstanceName, :BandWidth, :VpcId, :SubnetId, :InstanceType, :MsgRetentionTime, :ClusterId, :KafkaVersion, :SpecificationsType, :DiskType, :DiskSize, :Partition, :TopicNum, :ZoneId, :MultiZoneFlag, :ZoneIds, :InstanceNum, :PublicNetworkMonthly - + def initialize(instancename=nil, bandwidth=nil, vpcid=nil, subnetid=nil, instancetype=nil, msgretentiontime=nil, clusterid=nil, kafkaversion=nil, specificationstype=nil, disktype=nil, disksize=nil, partition=nil, topicnum=nil, zoneid=nil, multizoneflag=nil, zoneids=nil, instancenum=nil, publicnetworkmonthly=nil) @InstanceName = instancename @BandWidth = bandwidth @VpcId = vpcid @SubnetId = subnetid @@ -2006,11 +2006,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2037,11 +2037,11 @@ # @param DealNameInstanceIdMapping: 订单和购买实例对应映射列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type DealNameInstanceIdMapping: Array attr_accessor :FlowId, :DealNames, :InstanceId, :DealNameInstanceIdMapping - + def initialize(flowid=nil, dealnames=nil, instanceid=nil, dealnameinstanceidmapping=nil) @FlowId = flowid @DealNames = dealnames @InstanceId = instanceid @DealNameInstanceIdMapping = dealnameinstanceidmapping @@ -2103,11 +2103,11 @@ # @type ZoneIds: Array # @param PublicNetworkMonthly: 公网带宽大小，单位 Mbps。默认是没有加上免费 3Mbps 带宽。例如总共需要 3Mbps 公网带宽，此处传 0；总共需要 4Mbps 公网带宽，此处传 1。默认值为 0 # @type PublicNetworkMonthly: Integer attr_accessor :InstanceName, :ZoneId, :Period, :InstanceType, :VpcId, :SubnetId, :MsgRetentionTime, :ClusterId, :RenewFlag, :KafkaVersion, :SpecificationsType, :DiskSize, :BandWidth, :Partition, :Tags, :DiskType, :MultiZoneFlag, :ZoneIds, :PublicNetworkMonthly - + def initialize(instancename=nil, zoneid=nil, period=nil, instancetype=nil, vpcid=nil, subnetid=nil, msgretentiontime=nil, clusterid=nil, renewflag=nil, kafkaversion=nil, specificationstype=nil, disksize=nil, bandwidth=nil, partition=nil, tags=nil, disktype=nil, multizoneflag=nil, zoneids=nil, publicnetworkmonthly=nil) @InstanceName = instancename @ZoneId = zoneid @Period = period @InstanceType = instancetype @@ -2170,11 +2170,14 @@ # @param DeleteRouteTimestamp: 删除时间。目前该参数字段已废弃，将会在未来被删除 # 注意：此字段可能返回 null，表示取不到有效值。 # @type DeleteRouteTimestamp: String attr_accessor :ReturnCode, :ReturnMessage, :Data, :DeleteRouteTimestamp - + extend Gem::Deprecate + deprecate :DeleteRouteTimestamp, :none, 2023, 6 + deprecate :DeleteRouteTimestamp=, :none, 2023, 6 + def initialize(returncode=nil, returnmessage=nil, data=nil, deleteroutetimestamp=nil) @ReturnCode = returncode @ReturnMessage = returnmessage @Data = data @DeleteRouteTimestamp = deleteroutetimestamp @@ -2197,11 +2200,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.CreateInstancePreResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2222,11 +2225,11 @@ # @type TopicName: String # @param PartitionNum: 主题分区个数 # @type PartitionNum: Integer attr_accessor :InstanceId, :TopicName, :PartitionNum - + def initialize(instanceid=nil, topicname=nil, partitionnum=nil) @InstanceId = instanceid @TopicName = topicname @PartitionNum = partitionnum end @@ -2244,11 +2247,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2281,11 +2284,11 @@ # @type PublicNetwork: Integer # @param Ip: vip地址 # @type Ip: String attr_accessor :InstanceId, :VipType, :VpcId, :SubnetId, :AccessType, :AuthFlag, :CallerAppid, :PublicNetwork, :Ip - + def initialize(instanceid=nil, viptype=nil, vpcid=nil, subnetid=nil, accesstype=nil, authflag=nil, callerappid=nil, publicnetwork=nil, ip=nil) @InstanceId = instanceid @VipType = viptype @VpcId = vpcid @SubnetId = subnetid @@ -2315,11 +2318,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2338,11 +2341,11 @@ # @type InstanceId: String # @param User: 用户名 # @type User: String attr_accessor :InstanceId, :User - + def initialize(instanceid=nil, user=nil) @InstanceId = instanceid @User = user end @@ -2359,11 +2362,11 @@ # @type Result: String # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2381,11 +2384,11 @@ # @type TopicName: String # @param IpWhiteList: ip白名单列表 # @type IpWhiteList: Array attr_accessor :InstanceId, :TopicName, :IpWhiteList - + def initialize(instanceid=nil, topicname=nil, ipwhitelist=nil) @InstanceId = instanceid @TopicName = topicname @IpWhiteList = ipwhitelist end @@ -2403,11 +2406,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2456,11 +2459,11 @@ # @type RetentionBytes: Integer # @param Tags: 标签列表 # @type Tags: Array attr_accessor :InstanceId, :TopicName, :PartitionNum, :ReplicaNum, :EnableWhiteList, :IpWhiteList, :CleanUpPolicy, :Note, :MinInsyncReplicas, :UncleanLeaderElectionEnable, :RetentionMs, :SegmentMs, :MaxMessageBytes, :EnableAclRule, :AclRuleName, :RetentionBytes, :Tags - + def initialize(instanceid=nil, topicname=nil, partitionnum=nil, replicanum=nil, enablewhitelist=nil, ipwhitelist=nil, cleanuppolicy=nil, note=nil, mininsyncreplicas=nil, uncleanleaderelectionenable=nil, retentionms=nil, segmentms=nil, maxmessagebytes=nil, enableaclrule=nil, aclrulename=nil, retentionbytes=nil, tags=nil) @InstanceId = instanceid @TopicName = topicname @PartitionNum = partitionnum @ReplicaNum = replicanum @@ -2511,11 +2514,11 @@ class CreateTopicResp < TencentCloud::Common::AbstractModel # @param TopicId: 主题Id # @type TopicId: String attr_accessor :TopicId - + def initialize(topicid=nil) @TopicId = topicid end def deserialize(params) @@ -2529,11 +2532,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.CreateTopicResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2554,11 +2557,11 @@ # @type Name: String # @param Password: 用户密码 # @type Password: String attr_accessor :InstanceId, :Name, :Password - + def initialize(instanceid=nil, name=nil, password=nil) @InstanceId = instanceid @Name = name @Password = password end @@ -2576,11 +2579,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -2613,11 +2616,11 @@ # @param Resource: Ctsdb连接源的实例资源 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Resource: String attr_accessor :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :Resource - + def initialize(port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, resource=nil) @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @UserName = username @@ -2655,11 +2658,11 @@ # @param Resource: Ctsdb连接源的实例资源 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Resource: String attr_accessor :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :Resource - + def initialize(port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, resource=nil) @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @UserName = username @@ -2683,11 +2686,11 @@ # @type Resource: String # @param CtsdbMetric: Ctsdb的metric # @type CtsdbMetric: String attr_accessor :Resource, :CtsdbMetric - + def initialize(resource=nil, ctsdbmetric=nil) @Resource = resource @CtsdbMetric = ctsdbmetric end @@ -2749,11 +2752,11 @@ # @param ScfParam: Scf配置，Type为SCF时必填 # 注意：此字段可能返回 null，表示取不到有效值。 # @type ScfParam: :class:`Tencentcloud::Ckafka.v20190819.models.ScfParam` attr_accessor :Type, :KafkaParam, :EventBusParam, :MongoDBParam, :EsParam, :TdwParam, :DtsParam, :ClickHouseParam, :ClsParam, :CosParam, :MySQLParam, :PostgreSQLParam, :TopicParam, :MariaDBParam, :SQLServerParam, :CtsdbParam, :ScfParam - + def initialize(type=nil, kafkaparam=nil, eventbusparam=nil, mongodbparam=nil, esparam=nil, tdwparam=nil, dtsparam=nil, clickhouseparam=nil, clsparam=nil, cosparam=nil, mysqlparam=nil, postgresqlparam=nil, topicparam=nil, mariadbparam=nil, sqlserverparam=nil, ctsdbparam=nil, scfparam=nil) @Type = type @KafkaParam = kafkaparam @EventBusParam = eventbusparam @MongoDBParam = mongodbparam @@ -2846,11 +2849,11 @@ # @param TaskId: 任务id # 注意：此字段可能返回 null，表示取不到有效值。 # @type TaskId: String attr_accessor :TaskId - + def initialize(taskid=nil) @TaskId = taskid end def deserialize(params) @@ -2892,11 +2895,11 @@ # @param StepList: 步骤列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type StepList: Array attr_accessor :TaskId, :TaskName, :TaskType, :Status, :SourceResource, :TargetResource, :CreateTime, :ErrorMessage, :TaskProgress, :TaskCurrentStep, :DatahubId, :StepList - + def initialize(taskid=nil, taskname=nil, tasktype=nil, status=nil, sourceresource=nil, targetresource=nil, createtime=nil, errormessage=nil, taskprogress=nil, taskcurrentstep=nil, datahubid=nil, steplist=nil) @TaskId = taskid @TaskName = taskname @TaskType = tasktype @Status = status @@ -2948,11 +2951,11 @@ # @type Note: String # @param Status: 状态，1使用中，2删除中 # @type Status: Integer attr_accessor :Name, :TopicName, :TopicId, :PartitionNum, :RetentionMs, :Note, :Status - + def initialize(name=nil, topicname=nil, topicid=nil, partitionnum=nil, retentionms=nil, note=nil, status=nil) @Name = name @TopicName = topicname @TopicId = topicid @PartitionNum = partitionnum @@ -2979,11 +2982,11 @@ # @param TopicId: TopicId # 注意：此字段可能返回 null，表示取不到有效值。 # @type TopicId: String attr_accessor :TopicName, :TopicId - + def initialize(topicname=nil, topicid=nil) @TopicName = topicname @TopicId = topicid end @@ -3003,11 +3006,11 @@ # @param TimeZone: 时区，默认GMT+8 # 注意：此字段可能返回 null，表示取不到有效值。 # @type TimeZone: String attr_accessor :Format, :TargetType, :TimeZone - + def initialize(format=nil, targettype=nil, timezone=nil) @Format = format @TargetType = targettype @TimeZone = timezone end @@ -3027,11 +3030,11 @@ # @param InstanceIdList: 订单流水对应购买的 CKafka 实例 id 列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type InstanceIdList: Array attr_accessor :DealName, :InstanceIdList - + def initialize(dealname=nil, instanceidlist=nil) @DealName = dealname @InstanceIdList = instanceidlist end @@ -3057,11 +3060,11 @@ # @type Host: String # @param Principal: 用户列表，默认为*，表示任何user都可以访问，当前用户只能是用户列表中包含的用户 # @type Principal: String attr_accessor :InstanceId, :ResourceType, :ResourceName, :Operation, :PermissionType, :Host, :Principal - + def initialize(instanceid=nil, resourcetype=nil, resourcename=nil, operation=nil, permissiontype=nil, host=nil, principal=nil) @InstanceId = instanceid @ResourceType = resourcetype @ResourceName = resourcename @Operation = operation @@ -3087,11 +3090,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3110,11 +3113,11 @@ # @type InstanceId: String # @param RuleName: acl规则名称 # @type RuleName: String attr_accessor :InstanceId, :RuleName - + def initialize(instanceid=nil, rulename=nil) @InstanceId = instanceid @RuleName = rulename end @@ -3130,11 +3133,11 @@ # @type Result: Integer # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3148,11 +3151,11 @@ class DeleteConnectResourceRequest < TencentCloud::Common::AbstractModel # @param ResourceId: 连接源的Id # @type ResourceId: String attr_accessor :ResourceId - + def initialize(resourceid=nil) @ResourceId = resourceid end def deserialize(params) @@ -3166,11 +3169,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.ConnectResourceResourceIdResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3187,11 +3190,11 @@ class DeleteDatahubTaskRequest < TencentCloud::Common::AbstractModel # @param TaskId: 任务id # @type TaskId: String attr_accessor :TaskId - + def initialize(taskid=nil) @TaskId = taskid end def deserialize(params) @@ -3206,11 +3209,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DatahubTaskIdRes` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3227,11 +3230,11 @@ class DeleteDatahubTopicRequest < TencentCloud::Common::AbstractModel # @param Name: Topic名称 # @type Name: String attr_accessor :Name - + def initialize(name=nil) @Name = name end def deserialize(params) @@ -3245,11 +3248,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3268,11 +3271,11 @@ # @type InstanceId: String # @param Group: 消费分组 # @type Group: String attr_accessor :InstanceId, :Group - + def initialize(instanceid=nil, group=nil) @InstanceId = instanceid @Group = group end @@ -3288,11 +3291,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3309,11 +3312,11 @@ class DeleteInstancePreRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例id # @type InstanceId: String attr_accessor :InstanceId - + def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @@ -3327,11 +3330,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.CreateInstancePreResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3354,11 +3357,11 @@ # @type CallerAppid: Integer # @param DeleteRouteTime: 删除路由时间 # @type DeleteRouteTime: String attr_accessor :InstanceId, :RouteId, :CallerAppid, :DeleteRouteTime - + def initialize(instanceid=nil, routeid=nil, callerappid=nil, deleteroutetime=nil) @InstanceId = instanceid @RouteId = routeid @CallerAppid = callerappid @DeleteRouteTime = deleteroutetime @@ -3378,11 +3381,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3399,11 +3402,11 @@ class DeleteRouteTriggerTimeRequest < TencentCloud::Common::AbstractModel # @param DelayTime: 修改时间 # @type DelayTime: String attr_accessor :DelayTime - + def initialize(delaytime=nil) @DelayTime = delaytime end def deserialize(params) @@ -3415,11 +3418,11 @@ class DeleteRouteTriggerTimeResponse < TencentCloud::Common::AbstractModel # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :RequestId - + def initialize(requestid=nil) @RequestId = requestid end def deserialize(params) @@ -3435,11 +3438,11 @@ # @type TopicName: String # @param IpWhiteList: ip白名单列表 # @type IpWhiteList: Array attr_accessor :InstanceId, :TopicName, :IpWhiteList - + def initialize(instanceid=nil, topicname=nil, ipwhitelist=nil) @InstanceId = instanceid @TopicName = topicname @IpWhiteList = ipwhitelist end @@ -3457,11 +3460,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3480,11 +3483,11 @@ # @type InstanceId: String # @param TopicName: ckafka 主题名称 # @type TopicName: String attr_accessor :InstanceId, :TopicName - + def initialize(instanceid=nil, topicname=nil) @InstanceId = instanceid @TopicName = topicname end @@ -3500,11 +3503,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3523,11 +3526,11 @@ # @type InstanceId: String # @param Name: 用户名称 # @type Name: String attr_accessor :InstanceId, :Name - + def initialize(instanceid=nil, name=nil) @InstanceId = instanceid @Name = name end @@ -3543,11 +3546,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3574,11 +3577,11 @@ # @type Limit: Integer # @param SearchWord: 关键字匹配 # @type SearchWord: String attr_accessor :InstanceId, :ResourceType, :ResourceName, :Offset, :Limit, :SearchWord - + def initialize(instanceid=nil, resourcetype=nil, resourcename=nil, offset=nil, limit=nil, searchword=nil) @InstanceId = instanceid @ResourceType = resourcetype @ResourceName = resourcename @Offset = offset @@ -3602,11 +3605,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.AclResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3629,11 +3632,11 @@ # @type PatternType: String # @param IsSimplified: 是否读取简略的ACL规则 # @type IsSimplified: Boolean attr_accessor :InstanceId, :RuleName, :PatternType, :IsSimplified - + def initialize(instanceid=nil, rulename=nil, patterntype=nil, issimplified=nil) @InstanceId = instanceid @RuleName = rulename @PatternType = patterntype @IsSimplified = issimplified @@ -3653,11 +3656,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.AclRuleResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3676,11 +3679,11 @@ # @type Offset: Integer # @param Limit: 本次查询用户数目最大数量限制，最大值为50，默认50 # @type Limit: Integer attr_accessor :Offset, :Limit - + def initialize(offset=nil, limit=nil) @Offset = offset @Limit = limit end @@ -3696,11 +3699,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.AppIdResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3717,11 +3720,11 @@ class DescribeCkafkaZoneRequest < TencentCloud::Common::AbstractModel # @param CdcId: cdc专业集群业务参数 # @type CdcId: String attr_accessor :CdcId - + def initialize(cdcid=nil) @CdcId = cdcid end def deserialize(params) @@ -3735,11 +3738,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.ZoneResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -3763,11 +3766,11 @@ # @param IsUnSupportVersion: 是否支持的版本 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUnSupportVersion: Boolean attr_accessor :IpAddr, :Time, :IsUnSupportVersion - + def initialize(ipaddr=nil, time=nil, isunsupportversion=nil) @IpAddr = ipaddr @Time = time @IsUnSupportVersion = isunsupportversion end @@ -3847,11 +3850,11 @@ # @param KafkaConnectParam: Kafka配置，Type 为 KAFKA 时返回 # 注意：此字段可能返回 null，表示取不到有效值。 # @type KafkaConnectParam: :class:`Tencentcloud::Ckafka.v20190819.models.KafkaConnectParam` attr_accessor :ResourceId, :ResourceName, :Description, :Type, :Status, :CreateTime, :ErrorMessage, :DatahubTaskCount, :CurrentStep, :TaskProgress, :StepList, :DtsConnectParam, :MongoDBConnectParam, :EsConnectParam, :ClickHouseConnectParam, :MySQLConnectParam, :PostgreSQLConnectParam, :MariaDBConnectParam, :SQLServerConnectParam, :CtsdbConnectParam, :DorisConnectParam, :KafkaConnectParam - + def initialize(resourceid=nil, resourcename=nil, description=nil, type=nil, status=nil, createtime=nil, errormessage=nil, datahubtaskcount=nil, currentstep=nil, taskprogress=nil, steplist=nil, dtsconnectparam=nil, mongodbconnectparam=nil, esconnectparam=nil, clickhouseconnectparam=nil, mysqlconnectparam=nil, postgresqlconnectparam=nil, mariadbconnectparam=nil, sqlserverconnectparam=nil, ctsdbconnectparam=nil, dorisconnectparam=nil, kafkaconnectparam=nil) @ResourceId = resourceid @ResourceName = resourcename @Description = description @Type = type @@ -3938,11 +3941,11 @@ class DescribeConnectResourceRequest < TencentCloud::Common::AbstractModel # @param ResourceId: 连接源的Id # @type ResourceId: String attr_accessor :ResourceId - + def initialize(resourceid=nil) @ResourceId = resourceid end def deserialize(params) @@ -4012,11 +4015,11 @@ # @param KafkaConnectParam: Kafka配置，Type 为 KAFKA 时返回 # 注意：此字段可能返回 null，表示取不到有效值。 # @type KafkaConnectParam: :class:`Tencentcloud::Ckafka.v20190819.models.KafkaConnectParam` attr_accessor :ResourceId, :ResourceName, :Description, :Type, :Status, :CreateTime, :ErrorMessage, :CurrentStep, :StepList, :MySQLConnectParam, :PostgreSQLConnectParam, :DtsConnectParam, :MongoDBConnectParam, :EsConnectParam, :ClickHouseConnectParam, :MariaDBConnectParam, :SQLServerConnectParam, :CtsdbConnectParam, :DorisConnectParam, :KafkaConnectParam - + def initialize(resourceid=nil, resourcename=nil, description=nil, type=nil, status=nil, createtime=nil, errormessage=nil, currentstep=nil, steplist=nil, mysqlconnectparam=nil, postgresqlconnectparam=nil, dtsconnectparam=nil, mongodbconnectparam=nil, esconnectparam=nil, clickhouseconnectparam=nil, mariadbconnectparam=nil, sqlserverconnectparam=nil, ctsdbconnectparam=nil, dorisconnectparam=nil, kafkaconnectparam=nil) @ResourceId = resourceid @ResourceName = resourcename @Description = description @Type = type @@ -4102,11 +4105,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DescribeConnectResourceResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4131,11 +4134,11 @@ # @type Limit: Integer # @param ResourceRegion: 连接源的关键字查询, 根据地域查询本地域内连接管理列表中的连接(仅支持包含region输入的连接源) # @type ResourceRegion: String attr_accessor :Type, :SearchWord, :Offset, :Limit, :ResourceRegion - + def initialize(type=nil, searchword=nil, offset=nil, limit=nil, resourceregion=nil) @Type = type @SearchWord = searchword @Offset = offset @Limit = limit @@ -4158,11 +4161,11 @@ # @param ConnectResourceList: 连接源数据 # 注意：此字段可能返回 null，表示取不到有效值。 # @type ConnectResourceList: Array attr_accessor :TotalCount, :ConnectResourceList - + def initialize(totalcount=nil, connectresourcelist=nil) @TotalCount = totalcount @ConnectResourceList = connectresourcelist end @@ -4185,11 +4188,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DescribeConnectResourcesResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4214,11 +4217,11 @@ # @type Limit: Integer # @param Offset: 偏移位置 # @type Offset: Integer attr_accessor :InstanceId, :GroupName, :TopicName, :Limit, :Offset - + def initialize(instanceid=nil, groupname=nil, topicname=nil, limit=nil, offset=nil) @InstanceId = instanceid @GroupName = groupname @TopicName = topicname @Limit = limit @@ -4240,11 +4243,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.ConsumerGroupResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4269,11 +4272,11 @@ # @type Offset: Integer # @param Limit: 本次返回结果的最大个数，默认为50，最大值为50 # @type Limit: Integer attr_accessor :Name, :Group, :SearchWord, :Offset, :Limit - + def initialize(name=nil, group=nil, searchword=nil, offset=nil, limit=nil) @Name = name @Group = group @SearchWord = searchword @Offset = offset @@ -4295,11 +4298,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.GroupOffsetResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4316,11 +4319,11 @@ class DescribeDatahubTaskRequest < TencentCloud::Common::AbstractModel # @param TaskId: 任务id # @type TaskId: String attr_accessor :TaskId - + def initialize(taskid=nil) @TaskId = taskid end def deserialize(params) @@ -4371,11 +4374,11 @@ # @param Tags: 任务标签列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Tags: Array attr_accessor :TaskId, :TaskName, :TaskType, :Status, :SourceResource, :TargetResource, :Connections, :CreateTime, :TransformParam, :DatahubId, :SchemaId, :SchemaName, :TransformsParam, :ErrorMessage, :Tags - + def initialize(taskid=nil, taskname=nil, tasktype=nil, status=nil, sourceresource=nil, targetresource=nil, connections=nil, createtime=nil, transformparam=nil, datahubid=nil, schemaid=nil, schemaname=nil, transformsparam=nil, errormessage=nil, tags=nil) @TaskId = taskid @TaskName = taskname @TaskType = tasktype @Status = status @@ -4443,11 +4446,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DescribeDatahubTaskRes` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4476,11 +4479,11 @@ # @type SourceType: String # @param Resource: 转储的资源 # @type Resource: String attr_accessor :Limit, :Offset, :SearchWord, :TargetType, :TaskType, :SourceType, :Resource - + def initialize(limit=nil, offset=nil, searchword=nil, targettype=nil, tasktype=nil, sourcetype=nil, resource=nil) @Limit = limit @Offset = offset @SearchWord = searchword @TargetType = targettype @@ -4507,11 +4510,11 @@ # @param TaskList: Datahub任务信息列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type TaskList: Array attr_accessor :TotalCount, :TaskList - + def initialize(totalcount=nil, tasklist=nil) @TotalCount = totalcount @TaskList = tasklist end @@ -4534,11 +4537,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DescribeDatahubTasksRes` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4555,11 +4558,11 @@ class DescribeDatahubTopicRequest < TencentCloud::Common::AbstractModel # @param Name: 名称 # @type Name: String attr_accessor :Name - + def initialize(name=nil) @Name = name end def deserialize(params) @@ -4591,11 +4594,11 @@ # @param Address: 服务路由地址 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Address: String attr_accessor :Name, :TopicName, :TopicId, :PartitionNum, :RetentionMs, :Note, :UserName, :Password, :Status, :Address - + def initialize(name=nil, topicname=nil, topicid=nil, partitionnum=nil, retentionms=nil, note=nil, username=nil, password=nil, status=nil, address=nil) @Name = name @TopicName = topicname @TopicId = topicid @PartitionNum = partitionnum @@ -4627,11 +4630,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DescribeDatahubTopicResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4652,11 +4655,11 @@ # @type Offset: Integer # @param Limit: 本次返回结果的最大个数，默认为50，最大值为50 # @type Limit: Integer attr_accessor :SearchWord, :Offset, :Limit - + def initialize(searchword=nil, offset=nil, limit=nil) @SearchWord = searchword @Offset = offset @Limit = limit end @@ -4675,11 +4678,11 @@ # @param TopicList: Topic列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type TopicList: Array attr_accessor :TotalCount, :TopicList - + def initialize(totalcount=nil, topiclist=nil) @TotalCount = totalcount @TopicList = topiclist end @@ -4703,11 +4706,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DescribeDatahubTopicsResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4726,11 +4729,11 @@ # @type Group: String # @param Protocol: 该 group 使用的协议。 # @type Protocol: String attr_accessor :Group, :Protocol - + def initialize(group=nil, protocol=nil) @Group = group @Protocol = protocol end @@ -4746,11 +4749,11 @@ # @type InstanceId: String # @param GroupList: Kafka 消费分组，Consumer-group，这里是数组形式，格式：GroupList.0=xxx&GroupList.1=yyy。 # @type GroupList: Array attr_accessor :InstanceId, :GroupList - + def initialize(instanceid=nil, grouplist=nil) @InstanceId = instanceid @GroupList = grouplist end @@ -4767,11 +4770,11 @@ # @type Result: Array # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4802,11 +4805,11 @@ # @type Offset: Integer # @param Limit: 本次返回结果的最大个数，默认为50，最大值为50 # @type Limit: Integer attr_accessor :InstanceId, :Group, :Topics, :SearchWord, :Offset, :Limit - + def initialize(instanceid=nil, group=nil, topics=nil, searchword=nil, offset=nil, limit=nil) @InstanceId = instanceid @Group = group @Topics = topics @SearchWord = searchword @@ -4830,11 +4833,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.GroupOffsetResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4857,11 +4860,11 @@ # @type Offset: Integer # @param Limit: 最大返回数量 # @type Limit: Integer attr_accessor :InstanceId, :SearchWord, :Offset, :Limit - + def initialize(instanceid=nil, searchword=nil, offset=nil, limit=nil) @InstanceId = instanceid @SearchWord = searchword @Offset = offset @Limit = limit @@ -4881,11 +4884,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.GroupResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4902,11 +4905,11 @@ class DescribeInstanceAttributesRequest < TencentCloud::Common::AbstractModel # @param InstanceId: 实例id # @type InstanceId: String attr_accessor :InstanceId - + def initialize(instanceid=nil) @InstanceId = instanceid end def deserialize(params) @@ -4920,11 +4923,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.InstanceAttributesResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -4959,11 +4962,11 @@ # @type InstanceIdList: Array # @param TagList: 根据标签列表过滤实例（取交集） # @type TagList: Array attr_accessor :InstanceId, :SearchWord, :Status, :Offset, :Limit, :TagKey, :Filters, :InstanceIds, :InstanceIdList, :TagList - + def initialize(instanceid=nil, searchword=nil, status=nil, offset=nil, limit=nil, tagkey=nil, filters=nil, instanceids=nil, instanceidlist=nil, taglist=nil) @InstanceId = instanceid @SearchWord = searchword @Status = status @Offset = offset @@ -5009,11 +5012,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.InstanceDetailResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5042,11 +5045,11 @@ # @type TagKey: String # @param VpcId: 私有网络Id # @type VpcId: String attr_accessor :InstanceId, :SearchWord, :Status, :Offset, :Limit, :TagKey, :VpcId - + def initialize(instanceid=nil, searchword=nil, status=nil, offset=nil, limit=nil, tagkey=nil, vpcid=nil) @InstanceId = instanceid @SearchWord = searchword @Status = status @Offset = offset @@ -5072,11 +5075,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.InstanceResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5099,11 +5102,11 @@ # @type Business: String # @param CdcId: cdc专有集群业务字段，可忽略 # @type CdcId: String attr_accessor :Offset, :Limit, :Business, :CdcId - + def initialize(offset=nil, limit=nil, business=nil, cdcid=nil) @Offset = offset @Limit = limit @Business = business @CdcId = cdcid @@ -5124,11 +5127,11 @@ # @type Result: Array # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5151,11 +5154,11 @@ # @type InstanceId: String # @param RouteId: 路由id # @type RouteId: Integer attr_accessor :InstanceId, :RouteId - + def initialize(instanceid=nil, routeid=nil) @InstanceId = instanceid @RouteId = routeid end @@ -5171,11 +5174,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.RouteResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5192,11 +5195,11 @@ class DescribeTaskStatusRequest < TencentCloud::Common::AbstractModel # @param FlowId: 任务唯一标记 # @type FlowId: Integer attr_accessor :FlowId - + def initialize(flowid=nil) @FlowId = flowid end def deserialize(params) @@ -5210,11 +5213,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.TaskStatusResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5233,11 +5236,11 @@ # @type InstanceId: String # @param TopicName: 主题名称 # @type TopicName: String attr_accessor :InstanceId, :TopicName - + def initialize(instanceid=nil, topicname=nil) @InstanceId = instanceid @TopicName = topicname end @@ -5253,11 +5256,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.TopicAttributesResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5282,11 +5285,11 @@ # @type Limit: Integer # @param AclRuleName: Acl预设策略名称 # @type AclRuleName: String attr_accessor :InstanceId, :SearchWord, :Offset, :Limit, :AclRuleName - + def initialize(instanceid=nil, searchword=nil, offset=nil, limit=nil, aclrulename=nil) @InstanceId = instanceid @SearchWord = searchword @Offset = offset @Limit = limit @@ -5308,11 +5311,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.TopicDetailResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5335,11 +5338,11 @@ # @type BeginDate: String # @param EndDate: 排行结束日期 # @type EndDate: String attr_accessor :InstanceId, :RankingType, :BeginDate, :EndDate - + def initialize(instanceid=nil, rankingtype=nil, begindate=nil, enddate=nil) @InstanceId = instanceid @RankingType = rankingtype @BeginDate = begindate @EndDate = enddate @@ -5359,11 +5362,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.TopicFlowRankingResult` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5382,11 +5385,11 @@ # @type InstanceId: String # @param TopicName: topic名称 # @type TopicName: String attr_accessor :InstanceId, :TopicName - + def initialize(instanceid=nil, topicname=nil) @InstanceId = instanceid @TopicName = topicname end @@ -5402,11 +5405,11 @@ # @type Result: Array # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5435,11 +5438,11 @@ # @type Limit: Integer # @param AclRuleName: Acl预设策略名称 # @type AclRuleName: String attr_accessor :InstanceId, :SearchWord, :Offset, :Limit, :AclRuleName - + def initialize(instanceid=nil, searchword=nil, offset=nil, limit=nil, aclrulename=nil) @InstanceId = instanceid @SearchWord = searchword @Offset = offset @Limit = limit @@ -5462,11 +5465,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.TopicResult` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5489,11 +5492,11 @@ # @type Offset: Integer # @param Limit: 分页时的个数 # @type Limit: Integer attr_accessor :InstanceId, :TopicName, :Offset, :Limit - + def initialize(instanceid=nil, topicname=nil, offset=nil, limit=nil) @InstanceId = instanceid @TopicName = topicname @Offset = offset @Limit = limit @@ -5513,11 +5516,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.TopicSubscribeGroup` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5542,11 +5545,11 @@ # @type Limit: Integer # @param OutOfSyncReplicaOnly: 仅筛选未同步副本 # @type OutOfSyncReplicaOnly: Boolean attr_accessor :InstanceId, :TopicName, :Offset, :Limit, :OutOfSyncReplicaOnly - + def initialize(instanceid=nil, topicname=nil, offset=nil, limit=nil, outofsyncreplicaonly=nil) @InstanceId = instanceid @TopicName = topicname @Offset = offset @Limit = limit @@ -5568,11 +5571,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.TopicInSyncReplicaResult` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5595,11 +5598,11 @@ # @type Offset: Integer # @param Limit: 本次返回个数 # @type Limit: Integer attr_accessor :InstanceId, :SearchWord, :Offset, :Limit - + def initialize(instanceid=nil, searchword=nil, offset=nil, limit=nil) @InstanceId = instanceid @SearchWord = searchword @Offset = offset @Limit = limit @@ -5619,11 +5622,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.UserResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -5665,11 +5668,11 @@ # @param BePort: Doris 的 http 负载均衡连接 port，通常映射到 be 的 8040 端口 # 注意：此字段可能返回 null，表示取不到有效值。 # @type BePort: Integer attr_accessor :Port, :UserName, :Password, :Resource, :ServiceVip, :UniqVpcId, :IsUpdate, :SelfBuilt, :BePort - + def initialize(port=nil, username=nil, password=nil, resource=nil, servicevip=nil, uniqvpcid=nil, isupdate=nil, selfbuilt=nil, beport=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -5722,11 +5725,11 @@ # @param BePort: Doris 的 http 负载均衡连接 port，通常映射到 be 的 8040 端口 # 注意：此字段可能返回 null，表示取不到有效值。 # @type BePort: Integer attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :IsUpdate, :SelfBuilt, :BePort - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, isupdate=nil, selfbuilt=nil, beport=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -5767,11 +5770,11 @@ # @param DropClsLogSet: 投递cls的日志集id # 注意：此字段可能返回 null，表示取不到有效值。 # @type DropClsLogSet: String attr_accessor :DropInvalidMessageToCls, :DropClsRegion, :DropClsOwneruin, :DropClsTopicId, :DropClsLogSet - + def initialize(dropinvalidmessagetocls=nil, dropclsregion=nil, dropclsowneruin=nil, dropclstopicid=nil, dropclslogset=nil) @DropInvalidMessageToCls = dropinvalidmessagetocls @DropClsRegion = dropclsregion @DropClsOwneruin = dropclsowneruin @DropClsTopicId = dropclstopicid @@ -5810,11 +5813,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Port, :GroupId, :UserName, :Password, :Resource, :Topic, :IsUpdate - + def initialize(port=nil, groupid=nil, username=nil, password=nil, resource=nil, topic=nil, isupdate=nil) @Port = port @GroupId = groupid @UserName = username @Password = password @@ -5850,11 +5853,11 @@ # @type IsUpdate: Boolean # @param Topic: Dts订阅的topic【不支持修改】 # @type Topic: String attr_accessor :Resource, :Port, :GroupId, :UserName, :Password, :IsUpdate, :Topic - + def initialize(resource=nil, port=nil, groupid=nil, username=nil, password=nil, isupdate=nil, topic=nil) @Resource = resource @Port = port @GroupId = groupid @UserName = username @@ -5892,11 +5895,11 @@ # @type GroupPassword: String # @param TranSql: false同步原始数据，true同步解析后的json格式数据,默认true # @type TranSql: Boolean attr_accessor :Resource, :Ip, :Port, :Topic, :GroupId, :GroupUser, :GroupPassword, :TranSql - + def initialize(resource=nil, ip=nil, port=nil, topic=nil, groupid=nil, groupuser=nil, grouppassword=nil, transql=nil) @Resource = resource @Ip = ip @Port = port @Topic = topic @@ -5932,11 +5935,11 @@ # @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 @@ -5964,11 +5967,11 @@ # @param BottomRetention: 保底时长，单位分钟 # 注意：此字段可能返回 null，表示取不到有效值。 # @type BottomRetention: Integer attr_accessor :Enable, :DiskQuotaPercentage, :StepForwardPercentage, :BottomRetention - + def initialize(enable=nil, diskquotapercentage=nil, stepforwardpercentage=nil, bottomretention=nil) @Enable = enable @DiskQuotaPercentage = diskquotapercentage @StepForwardPercentage = stepforwardpercentage @BottomRetention = bottomretention @@ -6008,11 +6011,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Port, :UserName, :Password, :Resource, :SelfBuilt, :ServiceVip, :UniqVpcId, :IsUpdate - + def initialize(port=nil, username=nil, password=nil, resource=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, isupdate=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -6060,11 +6063,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :SelfBuilt, :IsUpdate - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, selfbuilt=nil, isupdate=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -6122,11 +6125,11 @@ # @type DatabasePrimaryKey: String # @param DropDlq: 死信队列 # @type DropDlq: :class:`Tencentcloud::Ckafka.v20190819.models.FailureParam` attr_accessor :Resource, :Port, :UserName, :Password, :SelfBuilt, :ServiceVip, :UniqVpcId, :DropInvalidMessage, :Index, :DateFormat, :ContentKey, :DropInvalidJsonMessage, :DocumentIdField, :IndexType, :DropCls, :DatabasePrimaryKey, :DropDlq - + 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) @Resource = resource @Port = port @UserName = username @Password = password @@ -6186,11 +6189,11 @@ # @type FunctionName: String # @param Qualifier: SCF云函数版本及别名 # @type Qualifier: String attr_accessor :Type, :SelfBuilt, :Resource, :Namespace, :FunctionName, :Qualifier - + def initialize(type=nil, selfbuilt=nil, resource=nil, namespace=nil, functionname=nil, qualifier=nil) @Type = type @SelfBuilt = selfbuilt @Resource = resource @Namespace = namespace @@ -6224,11 +6227,11 @@ # @param DlqType: 死信队列类型，CKAFKA，TOPIC # 注意：此字段可能返回 null，表示取不到有效值。 # @type DlqType: String attr_accessor :Type, :KafkaParam, :RetryInterval, :MaxRetryAttempts, :TopicParam, :DlqType - + def initialize(type=nil, kafkaparam=nil, retryinterval=nil, maxretryattempts=nil, topicparam=nil, dlqtype=nil) @Type = type @KafkaParam = kafkaparam @RetryInterval = retryinterval @MaxRetryAttempts = maxretryattempts @@ -6260,11 +6263,11 @@ # @type Partition: Integer # @param Offset: 位点信息，必填 # @type Offset: Integer attr_accessor :Name, :Partition, :Offset - + def initialize(name=nil, partition=nil, offset=nil) @Name = name @Partition = partition @Offset = offset end @@ -6282,11 +6285,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.ConsumerRecord` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -6309,11 +6312,11 @@ # @type Offset: Integer # @param MessageCount: 最大查询条数，最小1，最大100 # @type MessageCount: Integer attr_accessor :Name, :Partition, :Offset, :MessageCount - + def initialize(name=nil, partition=nil, offset=nil, messagecount=nil) @Name = name @Partition = partition @Offset = offset @MessageCount = messagecount @@ -6333,11 +6336,11 @@ # @type Result: Array # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -6364,11 +6367,11 @@ # @type Partition: Integer # @param Offset: 位点信息，必填 # @type Offset: Integer attr_accessor :InstanceId, :Topic, :Partition, :Offset - + def initialize(instanceid=nil, topic=nil, partition=nil, offset=nil) @InstanceId = instanceid @Topic = topic @Partition = partition @Offset = offset @@ -6388,11 +6391,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.ConsumerRecord` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -6417,11 +6420,11 @@ # @type Offset: Integer # @param SinglePartitionRecordNumber: 最大查询条数，默认20，最大20 # @type SinglePartitionRecordNumber: Integer attr_accessor :InstanceId, :Topic, :Partition, :Offset, :SinglePartitionRecordNumber - + def initialize(instanceid=nil, topic=nil, partition=nil, offset=nil, singlepartitionrecordnumber=nil) @InstanceId = instanceid @Topic = topic @Partition = partition @Offset = offset @@ -6443,11 +6446,11 @@ # @type Result: Array # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -6489,11 +6492,11 @@ # @param SecondaryAnalyseJsonResult: JSON格式二次解析结果 # 注意：此字段可能返回 null，表示取不到有效值。 # @type SecondaryAnalyseJsonResult: String attr_accessor :Analyse, :SecondaryAnalyse, :SMT, :Result, :AnalyseResult, :SecondaryAnalyseResult, :AnalyseJsonResult, :SecondaryAnalyseJsonResult - + def initialize(analyse=nil, secondaryanalyse=nil, smt=nil, result=nil, analyseresult=nil, secondaryanalyseresult=nil, analysejsonresult=nil, secondaryanalysejsonresult=nil) @Analyse = analyse @SecondaryAnalyse = secondaryanalyse @SMT = smt @Result = result @@ -6552,11 +6555,11 @@ # @type Name: String # @param Values: 字段的过滤值。 # @type Values: Array attr_accessor :Name, :Values - + def initialize(name=nil, values=nil) @Name = name @Values = values end @@ -6576,11 +6579,11 @@ # @type Value: String # @param Type: 固定REGULAR # @type Type: String attr_accessor :Key, :MatchMode, :Value, :Type - + def initialize(key=nil, matchmode=nil, value=nil, type=nil) @Key = key @MatchMode = matchmode @Value = value @Type = type @@ -6598,11 +6601,11 @@ class Group < TencentCloud::Common::AbstractModel # @param GroupName: 组名称 # @type GroupName: String attr_accessor :GroupName - + def initialize(groupname=nil) @GroupName = groupname end def deserialize(params) @@ -6620,11 +6623,11 @@ # @type ClientHost: String # @param Assignment: 存储着分配给该消费者的 partition 信息 # @type Assignment: :class:`Tencentcloud::Ckafka.v20190819.models.Assignment` attr_accessor :MemberId, :ClientId, :ClientHost, :Assignment - + def initialize(memberid=nil, clientid=nil, clienthost=nil, assignment=nil) @MemberId = memberid @ClientId = clientid @ClientHost = clienthost @Assignment = assignment @@ -6660,11 +6663,11 @@ # @type Members: Array # @param Group: Kafka 消费分组 # @type Group: String attr_accessor :ErrorCode, :State, :ProtocolType, :Protocol, :Members, :Group - + def initialize(errorcode=nil, state=nil, protocoltype=nil, protocol=nil, members=nil, group=nil) @ErrorCode = errorcode @State = state @ProtocolType = protocoltype @Protocol = protocol @@ -6696,11 +6699,11 @@ # @param Partitions: 分配的 partition 信息 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Partitions: Array attr_accessor :Topic, :Partitions - + def initialize(topic=nil, partitions=nil) @Topic = topic @Partitions = partitions end @@ -6725,11 +6728,11 @@ # @type LogEndOffset: Integer # @param Lag: 未消费的消息个数 # @type Lag: Integer attr_accessor :Partition, :Offset, :Metadata, :ErrorCode, :LogEndOffset, :Lag - + def initialize(partition=nil, offset=nil, metadata=nil, errorcode=nil, logendoffset=nil, lag=nil) @Partition = partition @Offset = offset @Metadata = metadata @ErrorCode = errorcode @@ -6754,11 +6757,11 @@ # @param TopicList: 该主题分区数组，其中每个元素为一个 json object # 注意：此字段可能返回 null，表示取不到有效值。 # @type TopicList: Array attr_accessor :TotalCount, :TopicList - + def initialize(totalcount=nil, topiclist=nil) @TotalCount = totalcount @TopicList = topiclist end @@ -6782,11 +6785,11 @@ # @param Partitions: 该主题分区数组，其中每个元素为一个 json object # 注意：此字段可能返回 null，表示取不到有效值。 # @type Partitions: Array attr_accessor :Topic, :Partitions - + def initialize(topic=nil, partitions=nil) @Topic = topic @Partitions = partitions end @@ -6814,11 +6817,11 @@ # @param GroupCountQuota: 消费分组配额 # 注意：此字段可能返回 null，表示取不到有效值。 # @type GroupCountQuota: Integer attr_accessor :TotalCount, :GroupList, :GroupCountQuota - + def initialize(totalcount=nil, grouplist=nil, groupcountquota=nil) @TotalCount = totalcount @GroupList = grouplist @GroupCountQuota = groupcountquota end @@ -6865,11 +6868,11 @@ # @type PublicNetworkParam: :class:`Tencentcloud::Ckafka.v20190819.models.InquiryPublicNetworkParam` # @param InstanceId: 续费时的实例id, 续费时填写 # @type InstanceId: String attr_accessor :InstanceType, :InstanceChargeParam, :InstanceNum, :Bandwidth, :InquiryDiskParam, :MessageRetention, :Topic, :Partition, :ZoneIds, :CategoryAction, :BillType, :PublicNetworkParam, :InstanceId - + def initialize(instancetype=nil, instancechargeparam=nil, instancenum=nil, bandwidth=nil, inquirydiskparam=nil, messageretention=nil, topic=nil, partition=nil, zoneids=nil, categoryaction=nil, billtype=nil, publicnetworkparam=nil, instanceid=nil) @InstanceType = instancetype @InstanceChargeParam = instancechargeparam @InstanceNum = instancenum @Bandwidth = bandwidth @@ -6918,11 +6921,11 @@ # @param PublicNetworkBandwidthPrice: 公网带宽价格 # 注意：此字段可能返回 null，表示取不到有效值。 # @type PublicNetworkBandwidthPrice: :class:`Tencentcloud::Ckafka.v20190819.models.InquiryPrice` attr_accessor :InstancePrice, :PublicNetworkBandwidthPrice - + def initialize(instanceprice=nil, publicnetworkbandwidthprice=nil) @InstancePrice = instanceprice @PublicNetworkBandwidthPrice = publicnetworkbandwidthprice end @@ -6944,11 +6947,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.InquireCkafkaPriceResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -6996,11 +6999,11 @@ # @param Value: 购买数量 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Value: Integer attr_accessor :UnitPrice, :UnitPriceDiscount, :OriginalPrice, :DiscountPrice, :Discount, :GoodsNum, :Currency, :DiskType, :TimeSpan, :TimeUnit, :Value - + def initialize(unitprice=nil, unitpricediscount=nil, originalprice=nil, discountprice=nil, discount=nil, goodsnum=nil, currency=nil, disktype=nil, timespan=nil, timeunit=nil, value=nil) @UnitPrice = unitprice @UnitPriceDiscount = unitpricediscount @OriginalPrice = originalprice @DiscountPrice = discountprice @@ -7045,11 +7048,11 @@ # @param InstanceTypePrice: 实例套餐价格 # 注意：此字段可能返回 null，表示取不到有效值。 # @type InstanceTypePrice: :class:`Tencentcloud::Ckafka.v20190819.models.InquiryBasePrice` attr_accessor :BandwidthPrice, :DiskPrice, :PartitionPrice, :TopicPrice, :InstanceTypePrice - + def initialize(bandwidthprice=nil, diskprice=nil, partitionprice=nil, topicprice=nil, instancetypeprice=nil) @BandwidthPrice = bandwidthprice @DiskPrice = diskprice @PartitionPrice = partitionprice @TopicPrice = topicprice @@ -7086,11 +7089,11 @@ # @type DiskType: String # @param DiskSize: 购买硬盘大小: 单位GB # @type DiskSize: Integer attr_accessor :DiskType, :DiskSize - + def initialize(disktype=nil, disksize=nil) @DiskType = disktype @DiskSize = disksize end @@ -7138,11 +7141,11 @@ # @param DetailPrices: 详细类别的价格 # 注意：此字段可能返回 null，表示取不到有效值。 # @type DetailPrices: :class:`Tencentcloud::Ckafka.v20190819.models.InquiryDetailPrice` attr_accessor :UnitPrice, :UnitPriceDiscount, :OriginalPrice, :DiscountPrice, :Discount, :GoodsNum, :Currency, :DiskType, :TimeSpan, :TimeUnit, :Value, :DetailPrices - + def initialize(unitprice=nil, unitpricediscount=nil, originalprice=nil, discountprice=nil, discount=nil, goodsnum=nil, currency=nil, disktype=nil, timespan=nil, timeunit=nil, value=nil, detailprices=nil) @UnitPrice = unitprice @UnitPriceDiscount = unitpricediscount @OriginalPrice = originalprice @DiscountPrice = discountprice @@ -7181,11 +7184,11 @@ # @type PublicNetworkChargeType: String # @param PublicNetworkMonthly: 公网带宽, 单位MB # @type PublicNetworkMonthly: Integer attr_accessor :PublicNetworkChargeType, :PublicNetworkMonthly - + def initialize(publicnetworkchargetype=nil, publicnetworkmonthly=nil) @PublicNetworkChargeType = publicnetworkchargetype @PublicNetworkMonthly = publicnetworkmonthly end @@ -7206,11 +7209,11 @@ # @param IfCommunity: 是否开源实例。开源：true，不开源：false # 注意：此字段可能返回 null，表示取不到有效值。 # @type IfCommunity: Boolean attr_accessor :InstanceId, :InstanceName, :Status, :IfCommunity - + def initialize(instanceid=nil, instancename=nil, status=nil, ifcommunity=nil) @InstanceId = instanceid @InstanceName = instancename @Status = status @IfCommunity = ifcommunity @@ -7311,11 +7314,11 @@ # @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, :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, dynamicdiskconfig=nil) @InstanceId = instanceid @InstanceName = instancename @VipList = viplist @Vip = vip @@ -7420,11 +7423,11 @@ # @type InstanceChargeType: String # @param InstanceChargePeriod: 购买时长: 包年包月时需要填写, 按量计费无需填写 # @type InstanceChargePeriod: Integer attr_accessor :InstanceChargeType, :InstanceChargePeriod - + def initialize(instancechargetype=nil, instancechargeperiod=nil) @InstanceChargeType = instancechargetype @InstanceChargePeriod = instancechargeperiod end @@ -7442,11 +7445,11 @@ # @type DefaultNumPartitions: Integer # @param DefaultReplicationFactor: 默认的复制Factor # @type DefaultReplicationFactor: Integer attr_accessor :AutoCreateTopicsEnable, :DefaultNumPartitions, :DefaultReplicationFactor - + def initialize(autocreatetopicsenable=nil, defaultnumpartitions=nil, defaultreplicationfactor=nil) @AutoCreateTopicsEnable = autocreatetopicsenable @DefaultNumPartitions = defaultnumpartitions @DefaultReplicationFactor = defaultreplicationfactor end @@ -7537,11 +7540,11 @@ # @param Features: 实例功能列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Features: Array attr_accessor :InstanceId, :InstanceName, :Vip, :Vport, :VipList, :Status, :Bandwidth, :DiskSize, :ZoneId, :VpcId, :SubnetId, :RenewFlag, :Healthy, :HealthyMessage, :CreateTime, :ExpireTime, :IsInternal, :TopicNum, :Tags, :Version, :ZoneIds, :Cvm, :InstanceType, :DiskType, :MaxTopicNumber, :MaxPartitionNumber, :RebalanceTime, :PartitionNumber, :PublicNetworkChargeType, :PublicNetwork, :ClusterType, :Features - + def initialize(instanceid=nil, instancename=nil, vip=nil, vport=nil, viplist=nil, status=nil, bandwidth=nil, disksize=nil, zoneid=nil, vpcid=nil, subnetid=nil, renewflag=nil, healthy=nil, healthymessage=nil, createtime=nil, expiretime=nil, isinternal=nil, topicnum=nil, tags=nil, version=nil, zoneids=nil, cvm=nil, instancetype=nil, disktype=nil, maxtopicnumber=nil, maxpartitionnumber=nil, rebalancetime=nil, partitionnumber=nil, publicnetworkchargetype=nil, publicnetwork=nil, clustertype=nil, features=nil) @InstanceId = instanceid @InstanceName = instancename @Vip = vip @Vport = vport @@ -7631,11 +7634,11 @@ # @type TotalCount: Integer # @param InstanceList: 符合条件的实例详情列表 # @type InstanceList: Array attr_accessor :TotalCount, :InstanceList - + def initialize(totalcount=nil, instancelist=nil) @TotalCount = totalcount @InstanceList = instancelist end @@ -7660,11 +7663,11 @@ # @param QuotaConsumerByteRate: 消费限流大小，单位 MB/s # 注意：此字段可能返回 null，表示取不到有效值。 # @type QuotaConsumerByteRate: Integer attr_accessor :QuotaProducerByteRate, :QuotaConsumerByteRate - + def initialize(quotaproducerbyterate=nil, quotaconsumerbyterate=nil) @QuotaProducerByteRate = quotaproducerbyterate @QuotaConsumerByteRate = quotaconsumerbyterate end @@ -7682,11 +7685,11 @@ # @param TotalCount: 符合条件的结果总数 # 注意：此字段可能返回 null，表示取不到有效值。 # @type TotalCount: Integer attr_accessor :InstanceList, :TotalCount - + def initialize(instancelist=nil, totalcount=nil) @InstanceList = instancelist @TotalCount = totalcount end @@ -7712,11 +7715,11 @@ # @param Data: 操作型返回的Data数据,可能有flowId等 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Data: :class:`Tencentcloud::Ckafka.v20190819.models.OperateResponseData` attr_accessor :ReturnCode, :ReturnMessage, :Data - + def initialize(returncode=nil, returnmessage=nil, data=nil) @ReturnCode = returncode @ReturnMessage = returnmessage @Data = data end @@ -7737,11 +7740,11 @@ # @type OldValue: String # @param NewValue: 替换值，Jsonpath表达式或字符串 # @type NewValue: String attr_accessor :OldValue, :NewValue - + def initialize(oldvalue=nil, newvalue=nil) @OldValue = oldvalue @NewValue = newvalue end @@ -7760,11 +7763,11 @@ # @param KeepOriginalKey: 保留源Key，默认为false不保留 # 注意：此字段可能返回 null，表示取不到有效值。 # @type KeepOriginalKey: String attr_accessor :Delimiter, :Regex, :KeepOriginalKey - + def initialize(delimiter=nil, regex=nil, keeporiginalkey=nil) @Delimiter = delimiter @Regex = regex @KeepOriginalKey = keeporiginalkey end @@ -7793,11 +7796,11 @@ # @param Region: CKafka连接源的实例资源地域, 跨地域时必填 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Region: String attr_accessor :Resource, :SelfBuilt, :IsUpdate, :BrokerAddress, :Region - + def initialize(resource=nil, selfbuilt=nil, isupdate=nil, brokeraddress=nil, region=nil) @Resource = resource @SelfBuilt = selfbuilt @IsUpdate = isupdate @BrokerAddress = brokeraddress @@ -7866,11 +7869,11 @@ # @param KeepPartition: 数据同步专用参数, 当通过时,希望下游的消息写入分区与上游的一致,则填true,但下游分区小于上游时,会报错; 不需要一致则为false, 默认为false # 注意：此字段可能返回 null，表示取不到有效值。 # @type KeepPartition: Boolean attr_accessor :SelfBuilt, :Resource, :Topic, :OffsetType, :StartTime, :ResourceName, :ZoneId, :TopicId, :PartitionNum, :EnableToleration, :QpsLimit, :TableMappings, :UseTableMapping, :UseAutoCreateTopic, :CompressionType, :MsgMultiple, :ConnectorSyncType, :KeepPartition - + def initialize(selfbuilt=nil, resource=nil, topic=nil, offsettype=nil, starttime=nil, resourcename=nil, zoneid=nil, topicid=nil, partitionnum=nil, enabletoleration=nil, qpslimit=nil, tablemappings=nil, usetablemapping=nil, useautocreatetopic=nil, compressiontype=nil, msgmultiple=nil, connectorsynctype=nil, keeppartition=nil) @SelfBuilt = selfbuilt @Resource = resource @Topic = topic @OffsetType = offsettype @@ -7920,11 +7923,11 @@ end # 小写字符解析 class LowercaseParam < TencentCloud::Common::AbstractModel - + def initialize() end def deserialize(params) end @@ -7938,11 +7941,11 @@ # @type Type: String # @param Value: 值 # @type Value: String attr_accessor :Key, :Type, :Value - + def initialize(key=nil, type=nil, value=nil) @Key = key @Type = type @Value = value end @@ -7977,11 +7980,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Port, :UserName, :Password, :Resource, :ServiceVip, :UniqVpcId, :IsUpdate - + def initialize(port=nil, username=nil, password=nil, resource=nil, servicevip=nil, uniqvpcid=nil, isupdate=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -8024,11 +8027,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :IsUpdate - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, isupdate=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -8070,11 +8073,11 @@ # @type IncludeQuery: Boolean # @param RecordWithSchema: 如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带 # @type RecordWithSchema: Boolean attr_accessor :Database, :Table, :Resource, :SnapshotMode, :KeyColumns, :IsTablePrefix, :OutputFormat, :IncludeContentChanges, :IncludeQuery, :RecordWithSchema - + def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, keycolumns=nil, istableprefix=nil, outputformat=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil) @Database = database @Table = table @Resource = resource @SnapshotMode = snapshotmode @@ -8108,11 +8111,11 @@ # @type RuleName: String # @param IsApplied: 是否应用到新增的Topic # @type IsApplied: Integer attr_accessor :InstanceId, :RuleName, :IsApplied - + def initialize(instanceid=nil, rulename=nil, isapplied=nil) @InstanceId = instanceid @RuleName = rulename @IsApplied = isapplied end @@ -8130,11 +8133,11 @@ # @type Result: Integer # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8176,11 +8179,11 @@ # @type DorisConnectParam: :class:`Tencentcloud::Ckafka.v20190819.models.DorisModifyConnectParam` # @param KafkaConnectParam: Kafka配置，Type为 KAFKA 时必填 # @type KafkaConnectParam: :class:`Tencentcloud::Ckafka.v20190819.models.KafkaConnectParam` attr_accessor :ResourceId, :ResourceName, :Description, :Type, :DtsConnectParam, :MongoDBConnectParam, :EsConnectParam, :ClickHouseConnectParam, :MySQLConnectParam, :PostgreSQLConnectParam, :MariaDBConnectParam, :SQLServerConnectParam, :CtsdbConnectParam, :DorisConnectParam, :KafkaConnectParam - + def initialize(resourceid=nil, resourcename=nil, description=nil, type=nil, dtsconnectparam=nil, mongodbconnectparam=nil, esconnectparam=nil, clickhouseconnectparam=nil, mysqlconnectparam=nil, postgresqlconnectparam=nil, mariadbconnectparam=nil, sqlserverconnectparam=nil, ctsdbconnectparam=nil, dorisconnectparam=nil, kafkaconnectparam=nil) @ResourceId = resourceid @ResourceName = resourcename @Description = description @Type = type @@ -8255,11 +8258,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.ConnectResourceResourceIdResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8278,11 +8281,11 @@ # @type TaskId: String # @param TaskName: 任务名称 # @type TaskName: String attr_accessor :TaskId, :TaskName - + def initialize(taskid=nil, taskname=nil) @TaskId = taskid @TaskName = taskname end @@ -8299,11 +8302,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.DatahubTaskIdRes` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8326,11 +8329,11 @@ # @type Note: String # @param Tags: 标签列表 # @type Tags: Array attr_accessor :Name, :RetentionMs, :Note, :Tags - + def initialize(name=nil, retentionms=nil, note=nil, tags=nil) @Name = name @RetentionMs = retentionms @Note = note @Tags = tags @@ -8357,11 +8360,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8392,11 +8395,11 @@ # @type Offset: Integer # @param Partitions: 需要重新设置的partition的列表，如果没有指定Topics参数。则重置全部topics的对应的Partition列表里的partition。指定Topics时则重置指定的topic列表的对应的Partitions列表的partition。 # @type Partitions: Array attr_accessor :InstanceId, :Group, :Strategy, :Topics, :Shift, :ShiftTimestamp, :Offset, :Partitions - + def initialize(instanceid=nil, group=nil, strategy=nil, topics=nil, shift=nil, shifttimestamp=nil, offset=nil, partitions=nil) @InstanceId = instanceid @Group = group @Strategy = strategy @Topics = topics @@ -8424,11 +8427,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8449,11 +8452,11 @@ # @type DefaultNumPartitions: Integer # @param DefaultReplicationFactor: 如歌auto.create.topic.enable设置为true没有指定该值时默认设置为2 # @type DefaultReplicationFactor: Integer attr_accessor :AutoCreateTopicEnable, :DefaultNumPartitions, :DefaultReplicationFactor - + def initialize(autocreatetopicenable=nil, defaultnumpartitions=nil, defaultreplicationfactor=nil) @AutoCreateTopicEnable = autocreatetopicenable @DefaultNumPartitions = defaultnumpartitions @DefaultReplicationFactor = defaultreplicationfactor end @@ -8485,11 +8488,11 @@ # @type DynamicDiskConfig: :class:`Tencentcloud::Ckafka.v20190819.models.DynamicDiskConfig` # @param MaxMessageByte: 实例级别单条消息大小（单位byte) # @type MaxMessageByte: Integer attr_accessor :InstanceId, :MsgRetentionTime, :InstanceName, :Config, :DynamicRetentionConfig, :RebalanceTime, :PublicNetwork, :DynamicDiskConfig, :MaxMessageByte - + def initialize(instanceid=nil, msgretentiontime=nil, instancename=nil, config=nil, dynamicretentionconfig=nil, rebalancetime=nil, publicnetwork=nil, dynamicdiskconfig=nil, maxmessagebyte=nil) @InstanceId = instanceid @MsgRetentionTime = msgretentiontime @InstanceName = instancename @Config = config @@ -8528,11 +8531,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8555,11 +8558,11 @@ # @type BandWidth: Integer # @param Partition: 预计分区，根据带宽步长，规格向上调整。 # @type Partition: Integer attr_accessor :InstanceId, :DiskSize, :BandWidth, :Partition - + def initialize(instanceid=nil, disksize=nil, bandwidth=nil, partition=nil) @InstanceId = instanceid @DiskSize = disksize @BandWidth = bandwidth @Partition = partition @@ -8579,11 +8582,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.CreateInstancePreResp` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8606,11 +8609,11 @@ # @type Password: String # @param PasswordNew: 用户新密码 # @type PasswordNew: String attr_accessor :InstanceId, :Name, :Password, :PasswordNew - + def initialize(instanceid=nil, name=nil, password=nil, passwordnew=nil) @InstanceId = instanceid @Name = name @Password = password @PasswordNew = passwordnew @@ -8630,11 +8633,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8685,11 +8688,11 @@ # @type QuotaConsumerByteRate: Integer # @param ReplicaNum: 调整topic副本数 # @type ReplicaNum: Integer attr_accessor :InstanceId, :TopicName, :Note, :EnableWhiteList, :MinInsyncReplicas, :UncleanLeaderElectionEnable, :RetentionMs, :SegmentMs, :MaxMessageBytes, :CleanUpPolicy, :IpWhiteList, :EnableAclRule, :AclRuleName, :RetentionBytes, :Tags, :QuotaProducerByteRate, :QuotaConsumerByteRate, :ReplicaNum - + 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, replicanum=nil) @InstanceId = instanceid @TopicName = topicname @Note = note @EnableWhiteList = enablewhitelist @@ -8744,11 +8747,11 @@ # @type Result: :class:`Tencentcloud::Ckafka.v20190819.models.JgwOperateResponse` # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :Result, :RequestId - + def initialize(result=nil, requestid=nil) @Result = result @RequestId = requestid end @@ -8787,11 +8790,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Port, :UserName, :Password, :Resource, :SelfBuilt, :ServiceVip, :UniqVpcId, :IsUpdate - + def initialize(port=nil, username=nil, password=nil, resource=nil, selfbuilt=nil, servicevip=nil, uniqvpcid=nil, isupdate=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -8839,11 +8842,11 @@ # @param IsUpdate: 是否更新到关联的Datahub任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :SelfBuilt, :IsUpdate - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, selfbuilt=nil, isupdate=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -8891,11 +8894,11 @@ # @type Pipeline: String # @param SelfBuilt: 是否为自建集群 # @type SelfBuilt: Boolean attr_accessor :Database, :Collection, :CopyExisting, :Resource, :Ip, :Port, :UserName, :Password, :ListeningEvent, :ReadPreference, :Pipeline, :SelfBuilt - + def initialize(database=nil, collection=nil, copyexisting=nil, resource=nil, ip=nil, port=nil, username=nil, password=nil, listeningevent=nil, readpreference=nil, pipeline=nil, selfbuilt=nil) @Database = database @Collection = collection @CopyExisting = copyexisting @Resource = resource @@ -8954,11 +8957,11 @@ # @param SelfBuilt: Mysql 连接源是否为自建集群 # 注意：此字段可能返回 null，表示取不到有效值。 # @type SelfBuilt: Boolean attr_accessor :Port, :UserName, :Password, :Resource, :ServiceVip, :UniqVpcId, :IsUpdate, :ClusterId, :SelfBuilt - + def initialize(port=nil, username=nil, password=nil, resource=nil, servicevip=nil, uniqvpcid=nil, isupdate=nil, clusterid=nil, selfbuilt=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -9011,11 +9014,11 @@ # @param SelfBuilt: 是否是自建的集群 # 注意：此字段可能返回 null，表示取不到有效值。 # @type SelfBuilt: Boolean attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :IsUpdate, :ClusterId, :SelfBuilt - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, isupdate=nil, clusterid=nil, selfbuilt=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -9091,11 +9094,11 @@ # @type SignalDatabase: String # @param IsTableRegular: 输入的table是否为正则表达式，如果该选项以及IsTablePrefix同时为true，该选项的判断优先级高于IsTablePrefix # @type IsTableRegular: Boolean attr_accessor :Database, :Table, :Resource, :SnapshotMode, :DdlTopic, :DataSourceMonitorMode, :DataSourceMonitorResource, :DataSourceIncrementMode, :DataSourceIncrementColumn, :DataSourceStartFrom, :DataTargetInsertMode, :DataTargetPrimaryKeyField, :DataTargetRecordMapping, :TopicRegex, :TopicReplacement, :KeyColumns, :DropInvalidMessage, :DropCls, :OutputFormat, :IsTablePrefix, :IncludeContentChanges, :IncludeQuery, :RecordWithSchema, :SignalDatabase, :IsTableRegular - + def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil, ddltopic=nil, datasourcemonitormode=nil, datasourcemonitorresource=nil, datasourceincrementmode=nil, datasourceincrementcolumn=nil, datasourcestartfrom=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, topicregex=nil, topicreplacement=nil, keycolumns=nil, dropinvalidmessage=nil, dropcls=nil, outputformat=nil, istableprefix=nil, includecontentchanges=nil, includequery=nil, recordwithschema=nil, signaldatabase=nil, istableregular=nil) @Database = database @Table = table @Resource = resource @SnapshotMode = snapshotmode @@ -9169,11 +9172,11 @@ # @param RouteDTO: RouteIdDto # 注意：此字段可能返回 null，表示取不到有效值。 # @type RouteDTO: :class:`Tencentcloud::Ckafka.v20190819.models.RouteDTO` attr_accessor :FlowId, :RouteDTO - + def initialize(flowid=nil, routedto=nil) @FlowId = flowid @RouteDTO = routedto end @@ -9190,11 +9193,11 @@ class Partition < TencentCloud::Common::AbstractModel # @param PartitionId: 分区ID # @type PartitionId: Integer attr_accessor :PartitionId - + def initialize(partitionid=nil) @PartitionId = partitionid end def deserialize(params) @@ -9210,11 +9213,11 @@ # @param Offset: Offset,例如100 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Offset: Integer attr_accessor :Partition, :Offset - + def initialize(partition=nil, offset=nil) @Partition = partition @Offset = offset end @@ -9230,11 +9233,11 @@ # @type Partition: Integer # @param Offset: partition 消费位移 # @type Offset: Integer attr_accessor :Partition, :Offset - + def initialize(partition=nil, offset=nil) @Partition = partition @Offset = offset end @@ -9273,11 +9276,11 @@ # @param SelfBuilt: PostgreSQL连接源是否为自建集群 # 注意：此字段可能返回 null，表示取不到有效值。 # @type SelfBuilt: Boolean attr_accessor :Port, :UserName, :Password, :Resource, :ServiceVip, :UniqVpcId, :ClusterId, :IsUpdate, :SelfBuilt - + def initialize(port=nil, username=nil, password=nil, resource=nil, servicevip=nil, uniqvpcid=nil, clusterid=nil, isupdate=nil, selfbuilt=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -9330,11 +9333,11 @@ # @param SelfBuilt: 是否为自建集群 # 注意：此字段可能返回 null，表示取不到有效值。 # @type SelfBuilt: Boolean attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :ClusterId, :IsUpdate, :SelfBuilt - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, clusterid=nil, isupdate=nil, selfbuilt=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -9386,11 +9389,11 @@ # @type KeyColumns: String # @param RecordWithSchema: 如果该值为 true，则消息中会携带消息结构体对应的schema，如果该值为false则不会携带 # @type RecordWithSchema: Boolean attr_accessor :Database, :Table, :Resource, :PluginName, :SnapshotMode, :DataFormat, :DataTargetInsertMode, :DataTargetPrimaryKeyField, :DataTargetRecordMapping, :DropInvalidMessage, :IsTableRegular, :KeyColumns, :RecordWithSchema - + def initialize(database=nil, table=nil, resource=nil, pluginname=nil, snapshotmode=nil, dataformat=nil, datatargetinsertmode=nil, datatargetprimarykeyfield=nil, datatargetrecordmapping=nil, dropinvalidmessage=nil, istableregular=nil, keycolumns=nil, recordwithschema=nil) @Database = database @Table = table @Resource = resource @PluginName = pluginname @@ -9435,11 +9438,11 @@ # @type RealTotalCost: Float # @param TotalCost: 原价 # @type TotalCost: Float attr_accessor :RealTotalCost, :TotalCost - + def initialize(realtotalcost=nil, totalcost=nil) @RealTotalCost = realtotalcost @TotalCost = totalcost end @@ -9455,11 +9458,11 @@ # @type ServiceVip: String # @param UniqVpcId: 客户实例的vpcId # @type UniqVpcId: String attr_accessor :ServiceVip, :UniqVpcId - + def initialize(servicevip=nil, uniqvpcid=nil) @ServiceVip = servicevip @UniqVpcId = uniqvpcid end @@ -9489,11 +9492,11 @@ # @type AutoIncrement: Boolean # @param DefaultValue: 数据库表默认参数 # @type DefaultValue: String attr_accessor :JsonKey, :Type, :AllowNull, :ColumnName, :ExtraInfo, :ColumnSize, :DecimalDigits, :AutoIncrement, :DefaultValue - + def initialize(jsonkey=nil, type=nil, allownull=nil, columnname=nil, extrainfo=nil, columnsize=nil, decimaldigits=nil, autoincrement=nil, defaultvalue=nil) @JsonKey = jsonkey @Type = type @AllowNull = allownull @ColumnName = columnname @@ -9523,11 +9526,11 @@ # @type Regex: String # @param NewValue: 替换新值 # @type NewValue: String attr_accessor :Regex, :NewValue - + def initialize(regex=nil, newvalue=nil) @Regex = regex @NewValue = newvalue end @@ -9560,11 +9563,11 @@ # @param MultiZone: 是否支持跨可用区, 0：表示不支持，1：表示支持 # 注意：此字段可能返回 null，表示取不到有效值。 # @type MultiZone: Integer attr_accessor :RegionId, :RegionName, :AreaName, :RegionCode, :RegionCodeV3, :Support, :Ipv6, :MultiZone - + def initialize(regionid=nil, regionname=nil, areaname=nil, regioncode=nil, regioncodev3=nil, support=nil, ipv6=nil, multizone=nil) @RegionId = regionid @RegionName = regionname @AreaName = areaname @RegionCode = regioncode @@ -9592,11 +9595,11 @@ # @type InstanceId: String # @param TimeSpan: 续费时长, 默认为1, 单位是月 # @type TimeSpan: Integer attr_accessor :InstanceId, :TimeSpan - + def initialize(instanceid=nil, timespan=nil) @InstanceId = instanceid @TimeSpan = timespan end @@ -9614,11 +9617,11 @@ # @param DealName: 子订单号 # 注意：此字段可能返回 null，表示取不到有效值。 # @type DealName: String attr_accessor :BigDealId, :DealName - + def initialize(bigdealid=nil, dealname=nil) @BigDealId = bigdealid @DealName = dealname end @@ -9634,11 +9637,11 @@ # @type OldValue: String # @param NewValue: 替换值 # @type NewValue: String attr_accessor :OldValue, :NewValue - + def initialize(oldvalue=nil, newvalue=nil) @OldValue = oldvalue @NewValue = newvalue end @@ -9671,11 +9674,11 @@ # @param DeleteTimestamp: 时间戳 # 注意：此字段可能返回 null，表示取不到有效值。 # @type DeleteTimestamp: String attr_accessor :AccessType, :RouteId, :VipType, :VipList, :Domain, :DomainPort, :DeleteTimestamp - + def initialize(accesstype=nil, routeid=nil, viptype=nil, viplist=nil, domain=nil, domainport=nil, deletetimestamp=nil) @AccessType = accesstype @RouteId = routeid @VipType = viptype @VipList = viplist @@ -9707,11 +9710,11 @@ # @param RouteId: RouteId11 # 注意：此字段可能返回 null，表示取不到有效值。 # @type RouteId: Integer attr_accessor :RouteId - + def initialize(routeid=nil) @RouteId = routeid end def deserialize(params) @@ -9724,11 +9727,11 @@ # @param Routers: 路由信息列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Routers: Array attr_accessor :Routers - + def initialize(routers=nil) @Routers = routers end def deserialize(params) @@ -9753,11 +9756,11 @@ # @param EntryDelimiter: 元素建的分隔符 # 注意：此字段可能返回 null，表示取不到有效值。 # @type EntryDelimiter: String attr_accessor :RowContent, :KeyValueDelimiter, :EntryDelimiter - + def initialize(rowcontent=nil, keyvaluedelimiter=nil, entrydelimiter=nil) @RowContent = rowcontent @KeyValueDelimiter = keyvaluedelimiter @EntryDelimiter = entrydelimiter end @@ -9789,11 +9792,11 @@ # @param ValueOperates: VALUE处理链 # 注意：此字段可能返回 null，表示取不到有效值。 # @type ValueOperates: Array attr_accessor :Key, :Operate, :SchemeType, :Value, :ValueOperate, :OriginalValue, :ValueOperates - + def initialize(key=nil, operate=nil, schemetype=nil, value=nil, valueoperate=nil, originalvalue=nil, valueoperates=nil) @Key = key @Operate = operate @SchemeType = schemetype @Value = value @@ -9846,11 +9849,11 @@ # @param IsUpdate: 是否更新到关联的Dip任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Port, :UserName, :Password, :Resource, :ServiceVip, :UniqVpcId, :IsUpdate - + def initialize(port=nil, username=nil, password=nil, resource=nil, servicevip=nil, uniqvpcid=nil, isupdate=nil) @Port = port @UserName = username @Password = password @Resource = resource @@ -9893,11 +9896,11 @@ # @param IsUpdate: 是否更新到关联的Dip任务 # 注意：此字段可能返回 null，表示取不到有效值。 # @type IsUpdate: Boolean attr_accessor :Resource, :Port, :ServiceVip, :UniqVpcId, :UserName, :Password, :IsUpdate - + def initialize(resource=nil, port=nil, servicevip=nil, uniqvpcid=nil, username=nil, password=nil, isupdate=nil) @Resource = resource @Port = port @ServiceVip = servicevip @UniqVpcId = uniqvpcid @@ -9927,11 +9930,11 @@ # @type Resource: String # @param SnapshotMode: 复制存量信息(schema_only增量, initial全量)，默认为initial # @type SnapshotMode: String attr_accessor :Database, :Table, :Resource, :SnapshotMode - + def initialize(database=nil, table=nil, resource=nil, snapshotmode=nil) @Database = database @Table = table @Resource = resource @SnapshotMode = snapshotmode @@ -9959,11 +9962,11 @@ # @param SoldOut: 售罄标志：true售罄 # 注意：此字段可能返回 null，表示取不到有效值。 # @type SoldOut: Boolean attr_accessor :Flag, :Version, :Platform, :SoldOut - + def initialize(flag=nil, version=nil, platform=nil, soldout=nil) @Flag = flag @Version = version @Platform = platform @SoldOut = soldout @@ -9989,11 +9992,11 @@ # @type BatchSize: Integer # @param MaxRetries: SCF调用失败后重试次数, 默认为5 # @type MaxRetries: Integer attr_accessor :FunctionName, :Namespace, :Qualifier, :BatchSize, :MaxRetries - + def initialize(functionname=nil, namespace=nil, qualifier=nil, batchsize=nil, maxretries=nil) @FunctionName = functionname @Namespace = namespace @Qualifier = qualifier @BatchSize = batchsize @@ -10013,11 +10016,11 @@ class SecondaryAnalyseParam < TencentCloud::Common::AbstractModel # @param Regex: 分隔符 # @type Regex: String attr_accessor :Regex - + def initialize(regex=nil) @Regex = regex end def deserialize(params) @@ -10031,11 +10034,11 @@ # @type DataHubId: String # @param Message: 发送消息内容(单次请求最多500条) # @type Message: Array attr_accessor :DataHubId, :Message - + def initialize(datahubid=nil, message=nil) @DataHubId = datahubid @Message = message end @@ -10058,11 +10061,11 @@ # @type MessageId: Array # @param RequestId: 唯一请求 ID，每次请求都会返回。定位问题时需要提供该次请求的 RequestId。 # @type RequestId: String attr_accessor :MessageId, :RequestId - + def initialize(messageid=nil, requestid=nil) @MessageId = messageid @RequestId = requestid end @@ -10076,11 +10079,11 @@ class SplitParam < TencentCloud::Common::AbstractModel # @param Regex: 分隔符 # @type Regex: String attr_accessor :Regex - + def initialize(regex=nil) @Regex = regex end def deserialize(params) @@ -10101,11 +10104,11 @@ # @param TopicId: 订阅的主题ID # 注意：此字段可能返回 null，表示取不到有效值。 # @type TopicId: String attr_accessor :TopicName, :Partition, :PartitionOffset, :TopicId - + def initialize(topicname=nil, partition=nil, partitionoffset=nil, topicid=nil) @TopicName = topicname @Partition = partition @PartitionOffset = partitionoffset @TopicId = topicid @@ -10132,11 +10135,11 @@ # @type Start: Integer # @param End: 截取截止位置 # @type End: Integer attr_accessor :Start, :End - + def initialize(start=nil, _end=nil) @Start = start @End = _end end @@ -10156,11 +10159,11 @@ # @type Topic: String # @param TopicId: Topic ID # @type TopicId: String attr_accessor :Database, :Table, :Topic, :TopicId - + def initialize(database=nil, table=nil, topic=nil, topicid=nil) @Database = database @Table = table @Topic = topic @TopicId = topicid @@ -10180,11 +10183,11 @@ # @type TagKey: String # @param TagValue: 标签的值 # @type TagValue: String attr_accessor :TagKey, :TagValue - + def initialize(tagkey=nil, tagvalue=nil) @TagKey = tagkey @TagValue = tagvalue end @@ -10204,11 +10207,11 @@ # @param Output: 输出信息 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Output: String attr_accessor :Status, :Output - + def initialize(status=nil, output=nil) @Status = status @Output = output end @@ -10230,11 +10233,11 @@ # @type TdwHost: String # @param TdwPort: TDW端口，默认8099 # @type TdwPort: Integer attr_accessor :Bid, :Tid, :IsDomestic, :TdwHost, :TdwPort - + def initialize(bid=nil, tid=nil, isdomestic=nil, tdwhost=nil, tdwport=nil) @Bid = bid @Tid = tid @IsDomestic = isdomestic @TdwHost = tdwhost @@ -10259,11 +10262,11 @@ # @param Note: 备注 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Note: String attr_accessor :TopicId, :TopicName, :Note - + def initialize(topicid=nil, topicname=nil, note=nil) @TopicId = topicid @TopicName = topicname @Note = note end @@ -10306,11 +10309,11 @@ # @param ReplicaNum: 副本数 # 注意：此字段可能返回 null，表示取不到有效值。 # @type ReplicaNum: Integer attr_accessor :TopicId, :CreateTime, :Note, :PartitionNum, :EnableWhiteList, :IpWhiteList, :Config, :Partitions, :EnableAclRule, :AclRuleList, :QuotaConfig, :ReplicaNum - + def initialize(topicid=nil, createtime=nil, note=nil, partitionnum=nil, enablewhitelist=nil, ipwhitelist=nil, config=nil, partitions=nil, enableaclrule=nil, aclrulelist=nil, quotaconfig=nil, replicanum=nil) @TopicId = topicid @CreateTime = createtime @Note = note @PartitionNum = partitionnum @@ -10398,11 +10401,11 @@ # @param Tags: 标签列表 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Tags: Array attr_accessor :TopicName, :TopicId, :PartitionNum, :ReplicaNum, :Note, :CreateTime, :EnableWhiteList, :IpWhiteListCount, :ForwardCosBucket, :ForwardStatus, :ForwardInterval, :Config, :RetentionTimeConfig, :Status, :Tags - + def initialize(topicname=nil, topicid=nil, partitionnum=nil, replicanum=nil, note=nil, createtime=nil, enablewhitelist=nil, ipwhitelistcount=nil, forwardcosbucket=nil, forwardstatus=nil, forwardinterval=nil, config=nil, retentiontimeconfig=nil, status=nil, tags=nil) @TopicName = topicname @TopicId = topicid @PartitionNum = partitionnum @ReplicaNum = replicanum @@ -10458,11 +10461,11 @@ # @type TopicList: Array # @param TotalCount: 符合条件的所有主题详情数量 # @type TotalCount: Integer attr_accessor :TopicList, :TotalCount - + def initialize(topiclist=nil, totalcount=nil) @TopicList = topiclist @TotalCount = totalcount end @@ -10493,11 +10496,11 @@ # @type TopicTraffic: String # @param MessageHeap: Topic 消息堆积 # @type MessageHeap: Integer attr_accessor :TopicId, :TopicName, :PartitionNum, :ReplicaNum, :TopicTraffic, :MessageHeap - + def initialize(topicid=nil, topicname=nil, partitionnum=nil, replicanum=nil, topictraffic=nil, messageheap=nil) @TopicId = topicid @TopicName = topicname @PartitionNum = partitionnum @ReplicaNum = replicanum @@ -10524,11 +10527,11 @@ # @param TopicMessageHeap: Topic 消息堆积/占用磁盘排行 # 注意：此字段可能返回 null，表示取不到有效值。 # @type TopicMessageHeap: Array attr_accessor :TopicFlow, :ConsumeSpeed, :TopicMessageHeap - + def initialize(topicflow=nil, consumespeed=nil, topicmessageheap=nil) @TopicFlow = topicflow @ConsumeSpeed = consumespeed @TopicMessageHeap = topicmessageheap end @@ -10583,11 +10586,11 @@ # @param OutOfSyncReplica: 未同步副本集 # 注意：此字段可能返回 null，表示取不到有效值。 # @type OutOfSyncReplica: String attr_accessor :Partition, :Leader, :Replica, :InSyncReplica, :BeginOffset, :EndOffset, :MessageCount, :OutOfSyncReplica - + def initialize(partition=nil, leader=nil, replica=nil, insyncreplica=nil, beginoffset=nil, endoffset=nil, messagecount=nil, outofsyncreplica=nil) @Partition = partition @Leader = leader @Replica = replica @InSyncReplica = insyncreplica @@ -10615,11 +10618,11 @@ # @type TopicInSyncReplicaList: Array # @param TotalCount: 总计个数 # @type TotalCount: Integer attr_accessor :TopicInSyncReplicaList, :TotalCount - + def initialize(topicinsyncreplicalist=nil, totalcount=nil) @TopicInSyncReplicaList = topicinsyncreplicalist @TotalCount = totalcount end @@ -10656,11 +10659,11 @@ # @param MessageHeap: topic消息堆积/占用磁盘 # 注意：此字段可能返回 null，表示取不到有效值。 # @type MessageHeap: Integer attr_accessor :TopicId, :TopicName, :PartitionNum, :ReplicaNum, :TopicTraffic, :MessageHeap - + def initialize(topicid=nil, topicname=nil, partitionnum=nil, replicanum=nil, topictraffic=nil, messageheap=nil) @TopicId = topicid @TopicName = topicname @PartitionNum = partitionnum @ReplicaNum = replicanum @@ -10700,11 +10703,11 @@ # @param MsgMultiple: 源topic消息1条扩增成msgMultiple条写入目标topic(该参数目前只有ckafka流入ckafka适用) # 注意：此字段可能返回 null，表示取不到有效值。 # @type MsgMultiple: Integer attr_accessor :Resource, :OffsetType, :StartTime, :TopicId, :CompressionType, :UseAutoCreateTopic, :MsgMultiple - + def initialize(resource=nil, offsettype=nil, starttime=nil, topicid=nil, compressiontype=nil, useautocreatetopic=nil, msgmultiple=nil) @Resource = resource @OffsetType = offsettype @StartTime = starttime @TopicId = topicid @@ -10734,11 +10737,11 @@ # @type IsrNum: Integer # @param ReplicaNum: 副本个数 # @type ReplicaNum: Integer attr_accessor :Partition, :LeaderStatus, :IsrNum, :ReplicaNum - + def initialize(partition=nil, leaderstatus=nil, isrnum=nil, replicanum=nil) @Partition = partition @LeaderStatus = leaderstatus @IsrNum = isrnum @ReplicaNum = replicanum @@ -10760,11 +10763,11 @@ # @param TotalCount: 符合条件的 topic 数量 # 注意：此字段可能返回 null，表示取不到有效值。 # @type TotalCount: Integer attr_accessor :TopicList, :TotalCount - + def initialize(topiclist=nil, totalcount=nil) @TopicList = topiclist @TotalCount = totalcount end @@ -10792,11 +10795,11 @@ # @param ModTimeStamp: 最近变更时间 # 注意：此字段可能返回 null，表示取不到有效值。 # @type ModTimeStamp: Integer attr_accessor :Expect, :Current, :ModTimeStamp - + def initialize(expect=nil, current=nil, modtimestamp=nil) @Expect = expect @Current = current @ModTimeStamp = modtimestamp end @@ -10820,11 +10823,11 @@ # @param Status: 此次请求是否异步的状态。实例里分组较少的会直接返回结果,Status为1。当分组较多时,会异步更新缓存，Status为0时不会返回分组信息，直至Status为1更新完毕返回结果。 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Status: Integer attr_accessor :TotalCount, :StatusCountInfo, :GroupsInfo, :Status - + def initialize(totalcount=nil, statuscountinfo=nil, groupsinfo=nil, status=nil) @TotalCount = totalcount @StatusCountInfo = statuscountinfo @GroupsInfo = groupsinfo @Status = status @@ -10872,11 +10875,11 @@ # @param UseEventBus: 底层引擎是否使用eb # 注意：此字段可能返回 null，表示取不到有效值。 # @type UseEventBus: Boolean attr_accessor :AnalysisFormat, :OutputFormat, :FailureParam, :Content, :SourceType, :Regex, :MapParam, :FilterParam, :Result, :AnalyseResult, :UseEventBus - + def initialize(analysisformat=nil, outputformat=nil, failureparam=nil, content=nil, sourcetype=nil, regex=nil, mapparam=nil, filterparam=nil, result=nil, analyseresult=nil, useeventbus=nil) @AnalysisFormat = analysisformat @OutputFormat = outputformat @FailureParam = failureparam @Content = content @@ -10958,11 +10961,11 @@ # @param BatchAnalyse: 数组解析 # 注意：此字段可能返回 null，表示取不到有效值。 # @type BatchAnalyse: :class:`Tencentcloud::Ckafka.v20190819.models.BatchAnalyseParam` attr_accessor :Content, :FieldChain, :FilterParam, :FailureParam, :Result, :SourceType, :OutputFormat, :RowParam, :KeepMetadata, :BatchAnalyse - + def initialize(content=nil, fieldchain=nil, filterparam=nil, failureparam=nil, result=nil, sourcetype=nil, outputformat=nil, rowparam=nil, keepmetadata=nil, batchanalyse=nil) @Content = content @FieldChain = fieldchain @FilterParam = filterparam @FailureParam = failureparam @@ -11016,11 +11019,11 @@ # @param CharsetName: 编码 # 注意：此字段可能返回 null，表示取不到有效值。 # @type CharsetName: String attr_accessor :CharsetName - + def initialize(charsetname=nil) @CharsetName = charsetname end def deserialize(params) @@ -11038,11 +11041,11 @@ # @type CreateTime: String # @param UpdateTime: 最后更新时间 # @type UpdateTime: String attr_accessor :UserId, :Name, :CreateTime, :UpdateTime - + def initialize(userid=nil, name=nil, createtime=nil, updatetime=nil) @UserId = userid @Name = name @CreateTime = createtime @UpdateTime = updatetime @@ -11063,11 +11066,11 @@ # @type Users: Array # @param TotalCount: 符合条件的总用户数 # @type TotalCount: Integer attr_accessor :Users, :TotalCount - + def initialize(users=nil, totalcount=nil) @Users = users @TotalCount = totalcount end @@ -11118,11 +11121,11 @@ # @param Lowercase: 小写字符解析 # 注意：此字段可能返回 null，表示取不到有效值。 # @type Lowercase: :class:`Tencentcloud::Ckafka.v20190819.models.LowercaseParam` attr_accessor :Type, :Replace, :Substr, :Date, :RegexReplace, :Split, :KV, :Result, :JsonPathReplace, :UrlDecode, :Lowercase - + def initialize(type=nil, replace=nil, substr=nil, date=nil, regexreplace=nil, split=nil, kv=nil, result=nil, jsonpathreplace=nil, urldecode=nil, lowercase=nil) @Type = type @Replace = replace @Substr = substr @Date = date @@ -11183,11 +11186,11 @@ # @type Vip: String # @param Vport: 虚拟端口 # @type Vport: String attr_accessor :Vip, :Vport - + def initialize(vip=nil, vport=nil) @Vip = vip @Vport = vport end @@ -11218,11 +11221,11 @@ # @param SalesInfo: 标准版售罄信息 # 注意：此字段可能返回 null，表示取不到有效值。 # @type SalesInfo: Array attr_accessor :ZoneId, :IsInternalApp, :AppId, :Flag, :ZoneName, :ZoneStatus, :Exflag, :SoldOut, :SalesInfo - + def initialize(zoneid=nil, isinternalapp=nil, appid=nil, flag=nil, zonename=nil, zonestatus=nil, exflag=nil, soldout=nil, salesinfo=nil) @ZoneId = zoneid @IsInternalApp = isinternalapp @AppId = appid @Flag = flag @@ -11286,10 +11289,10 @@ # @param PublicNetworkLimit: 公网带宽配置 # 注意：此字段可能返回 null，表示取不到有效值。 # @type PublicNetworkLimit: String attr_accessor :ZoneList, :MaxBuyInstanceNum, :MaxBandwidth, :UnitPrice, :MessagePrice, :ClusterInfo, :Standard, :StandardS2, :Profession, :Physical, :PublicNetwork, :PublicNetworkLimit - + def initialize(zonelist=nil, maxbuyinstancenum=nil, maxbandwidth=nil, unitprice=nil, messageprice=nil, clusterinfo=nil, standard=nil, standards2=nil, profession=nil, physical=nil, publicnetwork=nil, publicnetworklimit=nil) @ZoneList = zonelist @MaxBuyInstanceNum = maxbuyinstancenum @MaxBandwidth = maxbandwidth @UnitPrice = unitprice