Documentation ¶
Index ¶
- type Alarm
- type CaptureTaskStatus
- type ChangefeedReplicaConfig
- type CloudInstanceSpec
- type Column
- type ColumnObject
- type ColumnOption
- type ConfigurationOption
- type ConfigurationRule
- type ConnectivityTestResult
- type CustomOptions
- type DestinationEndpointRule
- type Endpoint
- type EndpointOther
- type FilterConfig
- type InstanceClass
- type Kernel
- type KernelOption
- type LogDetail
- type MongoBase
- type MongoDBCheckpoint
- type MongoLSN
- type Option
- type Phase
- type PipelineOptions
- type PreCheckItem
- type Process
- type Progress
- type ProgressDetail
- type Property
- type Retry
- type Schema
- type Table
- type TableObject
- type Tag
- type TaskProgress
- type TicdcChangefeedDetail
- type TicdcChangefeedInfo
- type TicdcError
- type Topic
- type Topology
- type TransmissionCheckpoint
- type TransmissionEndpoint
- type TransmissionMode
- type TransmissionObjectItem
- type TransmissionObjectOption
- type TransmissionTask
- type TransmissionTaskAttribute
- type TypeReserveField
- type Visibility
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Alarm ¶
type Alarm struct { /* 是否设置任务报警。开启:enable、关闭:disable (Optional) */ Status string `json:"status"` /* 是否设置任务异常报警,当任务传输异常时,触发告警。开启:enable、关闭:disable (Optional) */ ErrorAlarmStatus string `json:"errorAlarmStatus"` /* 是否设置任务延迟报警,当任务传输出现延迟,并超过延迟阈值时,触发告警。开启:enable、关闭:disable (Optional) */ DelayAlarmStatus string `json:"delayAlarmStatus"` /* 任务延迟阈值,超过该阈值时,触发报警 (Optional) */ DelayPeriod int `json:"delayPeriod"` /* 接受告警人电话 (Optional) */ Phone []string `json:"phone"` }
type CaptureTaskStatus ¶
type ChangefeedReplicaConfig ¶
type ChangefeedReplicaConfig struct { /* (Optional) */ Filter FilterConfig `json:"filter"` }
type CloudInstanceSpec ¶
type ColumnObject ¶
type ColumnOption ¶
type ConfigurationOption ¶
type ConfigurationOption struct { /* 任务配置属性(废弃) (Optional) */ TaskOption []Property `json:"taskOption"` /* 数据传输初始化类型 (Optional) */ TransmissionMode Property `json:"transmissionMode"` /* 任务设置项 (Optional) */ Options []Property `json:"options"` /* 传输对象配置支持的属性 (Optional) */ TransmissionObjectOption TransmissionObjectOption `json:"transmissionObjectOption"` /* 任务自定义设置项 (Optional) */ CustomOptions CustomOptions `json:"customOptions"` }
type ConfigurationRule ¶
type ConfigurationRule struct { /* (Optional) */ Endpoint Endpoint `json:"endpoint"` /* 源端、目标端映射规则 (Optional) */ SourceDestinationMap interface{} `json:"sourceDestinationMap"` }
type ConnectivityTestResult ¶
type CustomOptions ¶
type DestinationEndpointRule ¶
type EndpointOther ¶
type EndpointOther struct { /* (Optional) */ Other *string `json:"other"` }
type FilterConfig ¶
type InstanceClass ¶
type Kernel ¶
type Kernel struct { /* Kernel 名称 (Optional) */ Name string `json:"name"` /* topology详情 (Optional) */ Topology interface{} `json:"topology"` /* (Optional) */ ConfigurationOption ConfigurationOption `json:"configurationOption"` /* (Optional) */ ColumnOption ColumnOption `json:"columnOption"` }
type KernelOption ¶
type KernelOption struct { /* 示例,无实际意义 (Optional) */ Example string `json:"example"` }
type LogDetail ¶
type LogDetail struct { /* 日志类型 (Optional) */ Type string `json:"type"` /* 错误原因 (Optional) */ Reason string `json:"reason"` /* 错误信息 (Optional) */ Message string `json:"message"` /* 最后更新时间 (Optional) */ LastUpdateTime string `json:"lastUpdateTime"` /* 最后一次状态变更时间 (Optional) */ LastTransitionTime string `json:"lastTransitionTime"` }
type MongoBase ¶
type MongoBase struct { /* 数据库连接地址,域名或IP,InstanceType为OTHER时必填 (Optional) */ Host *string `json:"host"` /* 数据库监听端口,InstanceType为OTHER时必填 (Optional) */ Port *int `json:"port"` /* 数据库访问账号 (Optional) */ UserName *string `json:"userName"` /* 数据库访问密码 (Optional) */ Password *string `json:"password"` /* 传输对象所属的数据库名称 (Optional) */ DatabaseName *string `json:"databaseName"` }
type MongoDBCheckpoint ¶
type MongoDBCheckpoint struct { /* 源端的名字 (Optional) */ Replset *string `json:"replset"` /* 已经拉取的checkpoint位点(不一定写入) (Optional) */ Lsn *MongoLSN `json:"lsn"` /* 已经成功写入目的端的checkpoint位点(已经成功写入,但是不一定持久化) (Optional) */ LsnAck *MongoLSN `json:"lsnAck"` /* 已经成功持久化的checkpoint位点 (Optional) */ LsnCkpt *MongoLSN `json:"lsnCkpt"` /* 当前的时间 (Optional) */ Now *MongoLSN `json:"now"` }
type Option ¶
type Option struct { /* 标签名称 (Optional) */ Label *string `json:"label"` /* 参数值 (Optional) */ Value *string `json:"value"` /* 该参数的可见性 (Optional) */ Visibility []Visibility `json:"visibility"` /* 子节点 (Optional) */ Children []Option `json:"children"` }
type Phase ¶
type Phase struct { /* 数据传输任务所处阶段:结构初始化、全量初始化、增量传输 (Optional) */ Name string `json:"name"` }
type PipelineOptions ¶
type PipelineOptions struct { /* 目标插入策略:MySQL(mysql-replace-engine:覆盖写入,conflict-detect-engine:冲突检测报错)Clickhouse(ck-replaceMergeTree-engine) (Optional) */ DestExecutionStrategy *string `json:"destExecutionStrategy"` /* Elasticsearch 索引命名规则:table:使用表名,schemaTable:使用库名+'_'+表名(同步至Elasticsearch时,可选) (Optional) */ IndexNamingRule *string `json:"indexNamingRule"` /* 目标Kafka的消息格式:canal-json|open-protocol|canal|avro|maxwell(TiDB同步至Kafka时,可选) (Optional) */ Protocol *string `json:"protocol"` /* 消息投递到Kafka的策略:default(有多个唯一索引(包括主键)时按照 table 模式分发;只有一个唯一索引(或主键)按照 index-value 模式分发;如果开启了 old value 特性,按照 table 分发)|ts(以行变更的 commitTs 做 Hash 计算并进行 event 分发)|index-value(以表的主键或者唯一索引的值做 Hash 计算并进行 event 分发)|table(以表的 schema 名和 table 名做 Hash 计算并进行 event 分发)|zero(投递到0号分区) (Optional) */ Partition *string `json:"partition"` }
type PreCheckItem ¶
type PreCheckItem struct { /* 预检查项目名称 (Optional) */ Item string `json:"item"` /* 预检查项目描述 (Optional) */ Description string `json:"description"` /* 预检查结果 (Optional) */ Status string `json:"status"` /* 预检查结果详情 (Optional) */ Message string `json:"message"` /* 预检查项修复建议 (Optional) */ Advice string `json:"advice"` /* 该预检查项是否支持跳过 (Optional) */ CanSkip string `json:"canSkip"` /* 该预检查项是否已跳过 (Optional) */ IsSkip string `json:"isSkip"` }
type Process ¶
type Process struct { /* 流程ID (Optional) */ Id string `json:"id"` /* 地域 (Optional) */ Region string `json:"region"` /* 用户pin (Optional) */ Pin string `json:"pin"` /* 请求ID (Optional) */ RequestId string `json:"requestId"` /* 流程类型 (Optional) */ Type string `json:"type"` /* 流程名称 (Optional) */ Name string `json:"name"` /* 资源类型 (Optional) */ ResourceType string `json:"resourceType"` /* 资源ID (Optional) */ ResourceId string `json:"resourceId"` /* 状态名称 (Optional) */ StatusName string `json:"statusName"` /* 状态描述 (Optional) */ StatusDescription string `json:"statusDescription"` /* 当前步骤名称 (Optional) */ StepName string `json:"stepName"` /* 当前步骤描述 (Optional) */ StepDescription string `json:"stepDescription"` /* 上下文 (Optional) */ Context string `json:"context"` /* 进度 (Optional) */ Percent int `json:"percent"` /* 是否可见 (Optional) */ Visibility int `json:"visibility"` /* 创建时间 (Optional) */ Created string `json:"created"` /* 更新时间 (Optional) */ Updated string `json:"updated"` }
type ProgressDetail ¶
type ProgressDetail struct { /* 源Database名称 (Optional) */ SrcDatabaseName string `json:"srcDatabaseName"` /* 目标Database名称 (Optional) */ DestDatabaseName string `json:"destDatabaseName"` /* 源Table名称 (Optional) */ SrcTableName string `json:"srcTableName"` /* 目标Table名称 (Optional) */ DestTableName string `json:"destTableName"` /* 源Schema名称 (Optional) */ SrcSchemaName string `json:"srcSchemaName"` /* 目标Schema名称 (Optional) */ DestSchemaName string `json:"destSchemaName"` /* 全量数据初始化总数 (Optional) */ DataInitTotal int `json:"dataInitTotal"` /* 全量数据初始化完成数 (Optional) */ DataInitCompleted int `json:"dataInitCompleted"` /* 全量数据初始化耗时 (Optional) */ DataInitConsumeTime int `json:"dataInitConsumeTime"` /* 全量数据初始化状态 (Optional) */ DataInitStatus string `json:"dataInitStatus"` /* 结构数据初始化状态 (Optional) */ StructureInitStatus string `json:"structureInitStatus"` /* 增量传输状态 (Optional) */ DataSyncStatus string `json:"dataSyncStatus"` }
type Property ¶
type Property struct { /* 组件类型:el-select、el-input、el-radio-group、el-checkbox-group (Optional) */ ComponentType *string `json:"componentType"` /* 参数名称 (Optional) */ Variable *string `json:"variable"` /* 默认值 (Optional) */ DefaultValue *interface{} `json:"defaultValue"` /* 数据类型:int、string、array、object (Optional) */ DataType *string `json:"dataType"` /* 单位 (Optional) */ Unit *string `json:"unit"` /* 标签名称 (Optional) */ Label *string `json:"label"` /* 该参数的可选值 (Optional) */ Options []Option `json:"options"` /* 该参数描述 (Optional) */ Description *string `json:"description"` /* 该参数的可见性 (Optional) */ Visibility []Visibility `json:"visibility"` /* 其他配置参数 (Optional) */ AdditionalProperties *interface{} `json:"additionalProperties"` }
type Table ¶
type Table struct { /* 模式名称 (Optional) */ Schema string `json:"schema"` /* 表名称 (Optional) */ Name string `json:"name"` /* 表类型 (Optional) */ Tp string `json:"tp"` /* 表引擎 (Optional) */ Engine string `json:"engine"` /* 表行数 (Optional) */ TableRows string `json:"tableRows"` /* 表数据大小 (Optional) */ DataLength string `json:"dataLength"` /* 表索引大小 (Optional) */ IndexLength string `json:"indexLength"` /* 表字符序 (Optional) */ Collation string `json:"collation"` /* 主键、唯一键 (Optional) */ UniqueKey []string `json:"uniqueKey"` /* 字段 (Optional) */ Columns []Column `json:"columns"` /* 分布式表名称(Clickhouse) (Optional) */ DistributedTable string `json:"distributedTable"` }
type TableObject ¶
type TableObject struct { /* 目标 Schema 名称 (Optional) */ Name string `json:"name"` /* 目标分布式表名称(Clickhouse) (Optional) */ DistributedName string `json:"distributedName"` /* 目标 TypeName(Elasticsearch) (Optional) */ TypeName string `json:"typeName"` /* 是否传输该 Scheam 下所有 Table (Optional) */ All bool `json:"all"` /* 传输的 DML 操作列表 (Optional) */ DmlOp []string `json:"dmlOp"` /* 传输的 DDL 操作列表 (Optional) */ DdlOp []string `json:"ddlOp"` /* 传输的 DDL 操作列表 (Optional) */ Filter string `json:"filter"` /* (Optional) */ Columns interface{} `json:"columns"` /* (Optional) */ Reserve interface{} `json:"reserve"` }
type TaskProgress ¶
type TaskProgress struct { /* 数据传输任务ID (Optional) */ TaskId string `json:"taskId"` /* 结构初始化进度 (Optional) */ StructureInitialization Progress `json:"structureInitialization"` /* 数据初始化进度 (Optional) */ DataInitialization Progress `json:"dataInitialization"` /* 数据增量传输进度 (Optional) */ DataSynchronization Progress `json:"dataSynchronization"` /* 进度详情信息 (Optional) */ Details []ProgressDetail `json:"details"` }
type TicdcChangefeedDetail ¶
type TicdcChangefeedDetail struct { /* 同步任务 ID (Optional) */ Id string `json:"id"` /* 上游 ID (Optional) */ UpstreamId int `json:"upstreamId"` /* 命名空间 (Optional) */ Namespace string `json:"namespace"` /* 任务状态 (Optional) */ FeedState string `json:"feedState"` /* 任务Checkpoint TSO (Optional) */ CheckpointTso string `json:"checkpointTso"` /* 任务Checkpoint Time (Optional) */ CheckpointTime string `json:"checkpointTime"` /* (Optional) */ Error TicdcError `json:"error"` /* 目标端连接配置 (Optional) */ SinkUri string `json:"sinkUri"` /* (Optional) */ Config ChangefeedReplicaConfig `json:"config"` /* 任务创建时间 (Optional) */ CreateTime string `json:"createTime"` /* 任务启动位点 (Optional) */ StartTs string `json:"startTs"` /* 任务分析位点 (Optional) */ ResolvedTs string `json:"resolvedTs"` /* 任务目标位点 (Optional) */ TargetTs string `json:"targetTs"` /* (Optional) */ Engine string `json:"engine"` /* (Optional) */ ErrorHistory []int `json:"errorHistory"` /* (Optional) */ CreatorVersion string `json:"creatorVersion"` /* (Optional) */ TaskStatus CaptureTaskStatus `json:"taskStatus"` }
type TicdcChangefeedInfo ¶
type TicdcChangefeedInfo struct { /* 同步任务 ID (Optional) */ Id string `json:"id"` /* 上游 ID (Optional) */ UpstreamId int `json:"upstreamId"` /* 命名空间 (Optional) */ Namespace string `json:"namespace"` /* 任务状态 (Optional) */ FeedState string `json:"feedState"` /* 任务Checkpoint TSO (Optional) */ CheckpointTso string `json:"checkpointTso"` /* 任务Checkpoint Time (Optional) */ CheckpointTime string `json:"checkpointTime"` /* (Optional) */ Error TicdcError `json:"error"` }
type TicdcError ¶
type Topology ¶
type Topology struct { /* 源数据库引擎名称 (Optional) */ SourceEngine string `json:"sourceEngine"` /* 源实例类型:CloudInstance:RDS MySQL(MariaDB,Percona)、RDS SQL Server、RDS PostgreSQL、MongoDB、Kafka、Elasticsearch;ECS:云主机自建数据库;OTHER:有公网IP的自建数据库;EXPRESS:通过专线接入的数据库 (Optional) */ SourceInstanceType string `json:"sourceInstanceType"` /* 目标数据源引擎名称、目标数据源实例类型 (Optional) */ Destination []DestinationEndpointRule `json:"destination"` }
type TransmissionCheckpoint ¶
type TransmissionCheckpoint struct { /* 数据传输任务起始位点 MySQL GTID,当源库为MySQL,且为增量传输时,可传递此参数(仅限源为MySQL) (Optional) */ Gtid *string `json:"gtid"` /* 数据传输任务起始位点,MASTER_LOG_FILE,当源库为MySQL,且为增量传输时,可选择GTID或者LOG_FILE_POS(仅限源为MySQL) (Optional) */ LogFile *string `json:"logFile"` /* MySQL 数据传输任务开始位点,MASTER_LOG_POS(仅限源为MySQL) (Optional) */ LogPos *int `json:"logPos"` /* 数据传输任务延迟(仅限源为MySQL) (Optional) */ Delay *int `json:"delay"` /* MongoDB checkpoint (Optional) */ MongoDbCheckpoints []MongoDBCheckpoint `json:"mongoDbCheckpoints"` /* TiCDC checkpoint tso (Optional) */ CheckpointTSO *int `json:"checkpointTSO"` /* TiCDC checkpoint timestamp (Optional) */ CheckpointTime *string `json:"checkpointTime"` }
type TransmissionEndpoint ¶
type TransmissionEndpoint struct { /* 实例所在地域,若为京东云资源,则必须传入该参数 (Optional) */ Region *string `json:"region"` /* 实例类型:Replication(副本集)、Sharding(分片集)、Cluster(主从实例)、Readonly(只读实例) (Optional) */ Type *string `json:"type"` /* CloudInstance:RDS MySQL(MariaDB,Percona)、RDS SQL Server、RDS PostgreSQL、MongoDB、Kafka、Elasticsearch;ECS:云主机自建数据库;OTHER:有公网IP的自建数据库;EXPRESS:通过专线接入的数据库 (Optional) */ InstanceType *string `json:"instanceType"` /* 如果为云数据库实例,则传入云数据库实例ID;如果为ECS实例,则传入云主机ID (Optional) */ InstanceId *string `json:"instanceId"` /* 数据库类型,支持MySQL、Percona、MariaDB、PostgreSQL、MongoDB、Kafka、Elasticsearch、Clickhouse (Optional) */ Engine *string `json:"engine"` /* 数据库连接地址,域名或IP,InstanceType为OTHER时必填 (Optional) */ Host *string `json:"host"` /* 数据库监听端口,InstanceType为OTHER时必填 (Optional) */ Port *int `json:"port"` /* 数据库访问账号 (Optional) */ UserName *string `json:"userName"` /* 数据库访问密码 (Optional) */ Password *string `json:"password"` /* Topic名称 (Optional) */ Topic *string `json:"topic"` /* 传输对象所属的数据库名称 (Optional) */ DatabaseName *string `json:"databaseName"` /* 是否使用统一认证信息(若开启,mongos、mongoshards、configserver将使用相同的认证信息) (Optional) */ UnifiedAuth *bool `json:"unifiedAuth"` /* (Optional) */ Mongos []MongoBase `json:"mongos"` /* (Optional) */ MongoShards [][]MongoBase `json:"mongoShards"` /* (Optional) */ ConfigServer []MongoBase `json:"configServer"` /* (Optional) */ Other *EndpointOther `json:"other"` /* 数据库连接串,Kafka、MongoDB实例可选 (Optional) */ ConnectionStr *string `json:"connectionStr"` }
type TransmissionMode ¶
type TransmissionMode struct { /* 是否执行全量数据传输,取值:true:是,为默认值,false:否 (Optional) */ DataInitialization bool `json:"dataInitialization"` /* 是否执行增量数据传输,取值:false:否,为默认值,false:是 (Optional) */ DataSynchronization bool `json:"dataSynchronization"` /* 是否执行库表结构初始化,取值:true:是,false:否 (Optional) */ StructureInitialization bool `json:"structureInitialization"` }
type TransmissionObjectItem ¶
type TransmissionObjectItem struct { /* 目标 Schema 名称 (Optional) */ Name string `json:"name"` /* 是否传输该 Scheam 下所有 Table (Optional) */ All bool `json:"all"` /* 传输的 DML 操作列表 (Optional) */ DmlOp []string `json:"dmlOp"` /* 传输的 DDL 操作列表 (Optional) */ DdlOp []string `json:"ddlOp"` /* (Optional) */ Tables interface{} `json:"tables"` }
type TransmissionObjectOption ¶
type TransmissionObjectOption struct { /* schema 配置属性 (Optional) */ Schema []Property `json:"schema"` }
type TransmissionTask ¶
type TransmissionTask struct { /* 数据传输任务所属PIN (Optional) */ Pin string `json:"pin"` /* 数据传输任务所属地域 (Optional) */ Region string `json:"region"` /* 数据传输任务ID (Optional) */ TaskId string `json:"taskId"` /* 数据传输任务名称 (Optional) */ TaskName string `json:"taskName"` /* vpc (Optional) */ Vpc string `json:"vpc"` /* (Optional) */ Subnet string `json:"subnet"` /* 实例类型,取值为:Sync:同步、Subscribe:订阅、Migration:迁移、DisasterRecovery 灾备 (Optional) */ TransmissionMethod string `json:"transmissionMethod"` /* 数据传输拓扑,支持:oneway - 单向数据传输、bidirectional - 双向数据传输,默认取值为:oneway (Optional) */ Topology string `json:"topology"` /* 数据传输实例规格,支持:dts.m1.medium、dts.m1.large、dts.m1.xlarge (Optional) */ InstanceClass string `json:"instanceClass"` /* 数据传输任务所处阶段及描述 (Optional) */ Phase Phase `json:"phase"` /* 计费配置 (Optional) */ Charge charge.Charge `json:"charge"` /* 创建时间 (Optional) */ CreateTime string `json:"createTime"` /* Creating - 创建中 CreateFailed - 创建失败 NotStarted - 未启动 Modifying - 修改同步对象中 ModifyFailed - 修改同步对象失败 PreChecking - 预检查中 PreCheckFailed - 预检查失败 PreCheckSucceed - 预检查成功 Initializing - 任务初始化中 InitializeFailed - 任务初始化中失败 Running - 运行中 Failed - 同步失败 Suspending - 暂停 Retrying - 重试中 Expired - 锁定中 Finished - 结束 Deleting - 删除中 Deleted - 删除 (Optional) */ Status string `json:"status"` /* 源实例信息 (Optional) */ Source TransmissionEndpoint `json:"source"` /* 目标实例信息 (Optional) */ Destination TransmissionEndpoint `json:"destination"` /* 标签信息 (Optional) */ Tags []Tag `json:"tags"` /* 数据传输初始化类型 (Optional) */ TransmissionMode TransmissionMode `json:"transmissionMode"` }
type TransmissionTaskAttribute ¶
type TransmissionTaskAttribute struct { /* 数据传输任务ID (Optional) */ TaskId string `json:"taskId"` /* 数据传输任务名称 (Optional) */ TaskName string `json:"taskName"` /* vpc (Optional) */ Vpc string `json:"vpc"` /* (Optional) */ Subnet string `json:"subnet"` /* 实例类型,取值为:Sync:同步、Subscribe:订阅、Migration:迁移、DisasterRecovery 灾备 (Optional) */ TransmissionMethod string `json:"transmissionMethod"` /* 数据传输拓扑,支持:oneway - 单向数据传输、bidirectional - 双向数据传输,默认取值为:oneway (Optional) */ Topology string `json:"topology"` /* 数据传输实例规格,支持:dts.m1.medium、dts.m1.large、dts.m1.xlarge (Optional) */ InstanceClass string `json:"instanceClass"` /* 数据传输任务所处阶段及描述 (Optional) */ Phase Phase `json:"phase"` /* 计费配置 (Optional) */ Charge charge.Charge `json:"charge"` /* 创建时间 (Optional) */ CreateTime string `json:"createTime"` /* Creating - 创建中 CreateFailed - 创建失败 NotStarted - 未启动 Modifying - 修改同步对象中 ModifyFailed - 修改同步对象失败 PreChecking - 预检查中 PreCheckFailed - 预检查失败 PreCheckSucceed - 预检查成功 Initializing - 任务初始化中 InitializeFailed - 任务初始化中失败 Running - 运行中 Failed - 同步失败 Suspending - 暂停 Retrying - 重试中 Expired - 锁定中 Finished - 结束 Deleting - 删除中 Deleted - 删除 (Optional) */ Status string `json:"status"` /* 源实例信息 (Optional) */ Source TransmissionEndpoint `json:"source"` /* 目标实例信息 (Optional) */ Destination TransmissionEndpoint `json:"destination"` /* 标签信息 (Optional) */ Tags []Tag `json:"tags"` /* 数据传输初始化类型 (Optional) */ TransmissionMode TransmissionMode `json:"transmissionMode"` /* 目标端执行策略:MySQL:mysql-replace-engine(覆盖写入)、conflict-detect-engine(冲突报错);MongoDB:conflict-replace、conflict-detect (Optional) */ DestExecutionStrategy string `json:"destExecutionStrategy"` /* 自定义设置 (Optional) */ Options PipelineOptions `json:"options"` /* 任务自定义设置 (Optional) */ CustomOptions CustomOptions `json:"customOptions"` /* 数据传输任务检查点 (Optional) */ Checkpoint TransmissionCheckpoint `json:"checkpoint"` /* 数据传输任务检查点 (Optional) */ StartCheckPoint TransmissionCheckpoint `json:"startCheckPoint"` }
type TypeReserveField ¶
type Visibility ¶
type Visibility struct { /* 可见性策略:Always:总是可见、Property:当 propertyName 对应的参数值为 propertyValue 中的值时,该选项生效、Tag:当用户拥有 tagName 字段对应的标签时,该选项生效 (Optional) */ Strategy *string `json:"strategy"` /* tag 名称,当 strategy 为 Tag 时,该参数生效 (Optional) */ TagName *string `json:"tagName"` /* 参数名称,当 strategy 为 Property 时,该参数生效 (Optional) */ PropertyName *string `json:"propertyName"` /* 参数值,当 strategy 为 Property 时,该参数生效 (Optional) */ PropertyValue []string `json:"propertyValue"` }
Source Files ¶
- Alarm.go
- CaptureTaskStatus.go
- ChangefeedReplicaConfig.go
- CloudInstanceSpec.go
- Column.go
- ColumnObject.go
- ColumnOption.go
- ConfigurationOption.go
- ConfigurationRule.go
- ConnectivityTestResult.go
- CustomOptions.go
- DestinationEndpointRule.go
- Endpoint.go
- EndpointOther.go
- FilterConfig.go
- InstanceClass.go
- Kernel.go
- KernelOption.go
- LogDetail.go
- MongoBase.go
- MongoDBCheckpoint.go
- MongoLSN.go
- Option.go
- Phase.go
- PipelineOptions.go
- PreCheckItem.go
- Process.go
- Progress.go
- ProgressDetail.go
- Property.go
- Retry.go
- Schema.go
- Table.go
- TableObject.go
- Tag.go
- TaskProgress.go
- TicdcChangefeedDetail.go
- TicdcChangefeedInfo.go
- TicdcError.go
- Topic.go
- Topology.go
- TransmissionCheckpoint.go
- TransmissionEndpoint.go
- TransmissionMode.go
- TransmissionObjectItem.go
- TransmissionObjectOption.go
- TransmissionTask.go
- TransmissionTaskAttribute.go
- TypeReserveField.go
- Visibility.go
Click to show internal directories.
Click to hide internal directories.