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.