task

package
v0.0.18 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 18, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Overview

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright © 2020 Marvin

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at 

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AssessMigrateTask 

type AssessMigrateTask struct {
	ID           uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName     string  `gorm:"type:varchar(30);not null;uniqueIndex:uniq_task_name;comment:task name" json:"taskName"`
	SchemaNameS  string  `gorm:"type:varchar(60);not null;comment:source schema name" json:"schemaNameS"`
	TaskStatus   string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	AssessDetail string  `gorm:"type:longtext;comment:assess detail" json:"assessDetail"`
	AssessUser   string  `gorm:"type:varchar(200);comment:assess username" json:"assessUser"`
	AssessFile   string  `gorm:"type:varchar(300);comment:assess filename" json:"assessFile"`
	InitFlag     string  `gorm:"type:char(1);default:N;comment:the task table init flag" json:"initFlag"`
	AssessFlag   string  `gorm:"type:char(1);default:N;comment:the task table assess finished flag" json:"migrateFlag"`
	ErrorDetail  string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration     float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type DataCompareResult added in v0.0.6 

type DataCompareResult struct {
	ID           uint64 `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName     string `gorm:"type:varchar(30);not null;index:idx_schema_table_name_complex;comment:task name" json:"taskName"`
	SchemaNameS  string `gorm:"type:varchar(60);not null;index:idx_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableNameS   string `gorm:"type:varchar(60);not null;index:idx_schema_table_name_complex;comment:source table name" json:"tableNameS"`
	SchemaNameT  string `gorm:"type:varchar(60);not null;comment:target schema name" json:"schemaNameT"`
	TableNameT   string `gorm:"type:varchar(60);not null;comment:target table name" json:"tableNameT"`
	ChunkID      string `gorm:"type:varchar(300);not null;index:idx_schema_table_name_complex;comment:source table chunk random id" json:"chunkID"`
	ChunkDetailS string `gorm:"type:longtext;not null;comment:source table chunk detail" json:"chunkDetailS"`
	FixStmtType  string `gorm:"type:varchar(2);not null;comment:fix stmt type,eg: I represent INSERT D represent DELETE" json:"fixStmtType"`
	FixDetailT   string `gorm:"type:longtext;comment:fix detail infos used to query information" json:"fixDetailT"`
}

type DataCompareSummary 

type DataCompareSummary struct {
	ID             uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName       string  `` /* 129-byte string literal not displayed */
	SchemaNameS    string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableNameS     string  `gorm:"type:varchar(60);uniqueIndex:uniq_schema_table_name_complex;comment:source table name" json:"tableNameS"`
	SchemaNameT    string  `gorm:"type:varchar(60);not null;comment:target schema name" json:"schemaNameT"`
	TableNameT     string  `gorm:"type:varchar(60);not null;comment:target table name" json:"tableNameT"`
	SnapshotPointS string  `gorm:"type:varchar(120);comment:source snapshot point" json:"snapshotPointS"`
	SnapshotPointT string  `gorm:"type:varchar(120);comment:target snapshot point" json:"snapshotPointT"`
	TableRowsS     uint64  `gorm:"comment:source table rows" json:"tableRowsS"`
	TableSizeS     float64 `gorm:"comment:source table size (MB)" json:"tableSizeS"`
	ChunkTotals    uint64  `gorm:"type:int;comment:source table chunk totals" json:"chunkTotals"`
	ChunkEquals    uint64  `gorm:"type:int;comment:source table chunk equals" json:"chunkEquals"`
	ChunkNotEquals uint64  `gorm:"type:int;comment:source table chunk not equals" json:"chunkNotEquals"`
	ChunkFails     uint64  `gorm:"type:int;comment:source table chunk fails" json:"chunkFails"`
	ChunkWaits     uint64  `gorm:"type:int;comment:source table chunk waits" json:"chunkWaits"`
	ChunkRuns      uint64  `gorm:"type:int;comment:source table chunk runs" json:"chunkRuns"`
	ChunkStops     uint64  `gorm:"type:int;comment:source table chunk stops" json:"chunkStops"`
	InitFlag       string  `gorm:"type:char(1);default:N;comment:the task table init flag" json:"initFlag"`
	CompareFlag    string  `gorm:"type:char(1);default:N;comment:the task table compare finished flag" json:"compareFlag"`
	Duration       float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type DataCompareTask 

type DataCompareTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `` /* 129-byte string literal not displayed */
	SchemaNameS     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableNameS      string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source table name" json:"tableNameS"`
	SchemaNameT     string  `gorm:"type:varchar(60);not null;comment:target schema name" json:"schemaNameT"`
	TableNameT      string  `gorm:"type:varchar(60);not null;comment:target table name" json:"tableNameT"`
	TableTypeS      string  `gorm:"type:varchar(60);comment:source table type" json:"tableTypeS"`
	SnapshotPointS  string  `gorm:"type:varchar(120);comment:source snapshot point" json:"snapshotPointS"`
	SnapshotPointT  string  `gorm:"type:varchar(120);comment:target snapshot point" json:"snapshotPointT"`
	CompareMethod   string  `gorm:"type:varchar(50);not null;comment:compare method status" json:"compareMethod"`
	ColumnDetailSO  string  `gorm:"type:longtext;not null;comment:source table column origin detail" json:"columnDetailSO"`
	ColumnDetailS   string  `gorm:"type:longtext;comment:source column used to query information" json:"columnDetailS"`
	ColumnDetailTO  string  `gorm:"type:longtext;not null;comment:target table column origin detail" json:"columnDetailTO"`
	ColumnDetailT   string  `gorm:"type:longtext;comment:source column used to query information" json:"columnDetailT"`
	SqlHintS        string  `gorm:"type:varchar(300);comment:source sql hint" json:"sqlHintS"`
	SqlHintT        string  `gorm:"type:varchar(300);comment:target sql hint" json:"sqlHintT"`
	ChunkID         string  `` /* 128-byte string literal not displayed */
	ChunkDetailS    string  `gorm:"type:longtext;not null;comment:source table chunk detail" json:"chunkDetailS"`
	ChunkDetailT    string  `gorm:"type:longtext;not null;comment:target table chunk detail" json:"chunkDetailT"`
	ChunkDetailArgS string  `gorm:"type:longtext;comment:source table chunk detail args" json:"chunkDetailArgS"`
	ChunkDetailArgT string  `gorm:"type:longtext;comment:target table chunk detail args" json:"chunkDetailArgT"`
	ConsistentReadS string  `gorm:"type:varchar(10);comment:source sql consistent read" json:"consistentReadS"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	ErrorDetail     string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type DataGroupChunkResult 

type DataGroupChunkResult struct {
	TaskName    string `json:"taskName"`
	SchemaNameS string `json:"schemaNameS"`
	TableNameS  string `json:"tableNameS"`
	ChunkTotals int64  `json:"chunkTotals"`
}

type DataGroupStatusResult 

type DataGroupStatusResult struct {
	TaskName     string `json:"taskName"`
	TaskStatus   string `json:"taskStatus"`
	StatusCounts int64  `json:"statusCounts"`
}

type DataGroupTaskStatusResult 

type DataGroupTaskStatusResult struct {
	TaskName     string `json:"taskName"`
	SchemaNameS  string `json:"schemaNameS"`
	TableNameS   string `json:"tableNameS"`
	TaskStatus   string `json:"taskStatus"`
	StatusTotals int64  `json:"statusTotals"`
}

type DataMigrateSummary 

type DataMigrateSummary struct {
	ID             uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName       string  `` /* 129-byte string literal not displayed */
	SchemaNameS    string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableNameS     string  `gorm:"type:varchar(60);uniqueIndex:uniq_schema_table_name_complex;comment:source table name" json:"tableNameS"`
	SchemaNameT    string  `gorm:"type:varchar(60);not null;comment:target schema name" json:"schemaNameT"`
	TableNameT     string  `gorm:"type:varchar(60);not null;comment:target table name" json:"tableNameT"`
	SnapshotPointS string  `gorm:"type:varchar(120);comment:source snapshot point" json:"snapshotPointS"`
	TableRowsS     uint64  `gorm:"comment:source table rows" json:"tableRowsS"`
	TableSizeS     float64 `gorm:"comment:source table size (MB)" json:"tableSizeS"`
	ChunkTotals    uint64  `gorm:"type:int;comment:source table chunk totals" json:"chunkTotals"`
	ChunkSuccess   uint64  `gorm:"type:int;comment:source table chunk success" json:"chunkSuccess"`
	ChunkFails     uint64  `gorm:"type:int;comment:source table chunk fails" json:"chunkFails"`
	ChunkWaits     uint64  `gorm:"type:int;comment:source table chunk waits" json:"chunkWaits"`
	ChunkRuns      uint64  `gorm:"type:int;comment:source table chunk runs" json:"chunkRuns"`
	ChunkStops     uint64  `gorm:"type:int;comment:source table chunk stops" json:"chunkStops"`
	InitFlag       string  `gorm:"type:char(1);default:N;comment:the task table init flag" json:"initFlag"`
	MigrateFlag    string  `gorm:"type:char(1);default:N;comment:the task table migrate finished flag" json:"migrateFlag"`
	Refused        string  `gorm:"type:text;comment:csv migrate table refused" json:"refused"`
	Duration       float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type DataMigrateTask 

type DataMigrateTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `` /* 129-byte string literal not displayed */
	SchemaNameS     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableNameS      string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source table name" json:"tableNameS"`
	SchemaNameT     string  `gorm:"type:varchar(60);not null;comment:target schema name" json:"schemaNameT"`
	TableNameT      string  `gorm:"type:varchar(60);not null;comment:target table name" json:"tableNameT"`
	TableTypeS      string  `gorm:"type:varchar(60);comment:source table type" json:"tableTypeS"`
	SnapshotPointS  string  `gorm:"type:varchar(120);comment:source snapshot point" json:"snapshotPointS"`
	ColumnDetailO   string  `gorm:"type:longtext;comment:source column store origin information" json:"columnDetailO"`
	ColumnDetailS   string  `gorm:"type:longtext;comment:source column used to query information" json:"columnDetailS"`
	ColumnDetailT   string  `gorm:"type:longtext;comment:source column used to query information" json:"columnDetailT"`
	SqlHintS        string  `gorm:"type:varchar(300);comment:source sql hint" json:"sqlHintS"`
	SqlHintT        string  `gorm:"type:varchar(300);comment:target sql hint" json:"sqlHintT"`
	ChunkID         string  `` /* 128-byte string literal not displayed */
	ChunkDetailS    string  `gorm:"type:longtext;not null;comment:source table chunk detail" json:"chunkDetailS"`
	ChunkDetailArgS string  `gorm:"type:longtext;comment:source table chunk detail args" json:"chunkDetailArgS"`
	ConsistentReadS string  `gorm:"type:varchar(10);comment:source sql consistent read" json:"consistentReadS"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	CsvFile         string  `gorm:"type:varchar(300);comment:csv exporter file path" json:"csvFile"`
	ErrorDetail     string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type DataScanSummary 

type DataScanSummary struct {
	ID             uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName       string  `` /* 129-byte string literal not displayed */
	SchemaNameS    string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableNameS     string  `gorm:"type:varchar(60);uniqueIndex:uniq_schema_table_name_complex;comment:source table name" json:"tableNameS"`
	SnapshotPointS string  `gorm:"type:varchar(120);comment:source snapshot point" json:"snapshotPointS"`
	TableRowsS     uint64  `gorm:"comment:source table rows" json:"tableRowsS"`
	TableSizeS     float64 `gorm:"comment:source table size (MB)" json:"tableSizeS"`
	ChunkTotals    uint64  `gorm:"type:int;comment:source table chunk totals" json:"chunkTotals"`
	ChunkSuccess   uint64  `gorm:"type:int;comment:source table chunk success" json:"chunkSuccess"`
	ChunkFails     uint64  `gorm:"type:int;comment:source table chunk fails" json:"chunkFails"`
	ChunkWaits     uint64  `gorm:"type:int;comment:source table chunk waits" json:"chunkWaits"`
	ChunkRuns      uint64  `gorm:"type:int;comment:source table chunk runs" json:"chunkRuns"`
	ChunkStops     uint64  `gorm:"type:int;comment:source table chunk stops" json:"chunkStops"`
	Duration       float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	InitFlag       string  `gorm:"type:char(1);default:N;comment:the task table init flag" json:"initFlag"`
	ScanFlag       string  `gorm:"type:char(1);default:N;comment:the task table scan finished flag" json:"scanFlag"`
	*common.Entity
}

type DataScanTask 

type DataScanTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `` /* 129-byte string literal not displayed */
	SchemaNameS     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableNameS      string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source table name" json:"tableNameS"`
	TableTypeS      string  `gorm:"type:varchar(60);comment:source table type" json:"tableTypeS"`
	SnapshotPointS  string  `gorm:"type:varchar(120);comment:source snapshot point" json:"snapshotPointS"`
	ColumnDetailS   string  `gorm:"type:longtext;comment:source column used to query information" json:"columnDetailS"`
	GroupColumnS    string  `gorm:"type:longtext;comment:source column used to group column information" json:"groupColumnS"`
	SqlHintS        string  `gorm:"type:varchar(300);comment:source sql hint" json:"sqlHintS"`
	Samplerate      string  `gorm:"type:varchar(100);not null;comment:source table samplerate" json:"samplerate"`
	ChunkID         string  `` /* 128-byte string literal not displayed */
	ChunkDetailS    string  `gorm:"type:longtext;not null;comment:source table chunk detail" json:"chunkDetailS"`
	ChunkDetailArgS string  `gorm:"type:longtext;comment:source table chunk detail args" json:"chunkDetailArgS"`
	ConsistentReadS string  `gorm:"type:varchar(10);comment:source sql consistent read" json:"consistentReadS"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	ScanResult      string  `gorm:"type:longtext;not null;comment:task scan result" json:"scanResult"`
	ErrorDetail     string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type IAssessMigrateTask 

type IAssessMigrateTask interface {
	CreateAssessMigrateTask(ctx context.Context, task *AssessMigrateTask) (*AssessMigrateTask, error)
	GetAssessMigrateTask(ctx context.Context, task *AssessMigrateTask) (*AssessMigrateTask, error)
	QueryAssessMigrateTask(ctx context.Context, task *AssessMigrateTask) ([]*AssessMigrateTask, error)
	UpdateAssessMigrateTask(ctx context.Context, task *AssessMigrateTask, updates map[string]interface{}) (*AssessMigrateTask, error)
	ListAssessMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*AssessMigrateTask, error)
	DeleteAssessMigrateTask(ctx context.Context, id uint64) error
	DeleteAssessMigrateTaskName(ctx context.Context, taskName []string) error
}

type IDataCompareResult added in v0.0.6 

type IDataCompareResult interface {
	CreateDataCompareResult(ctx context.Context, task *DataCompareResult) (*DataCompareResult, error)
	FindDataCompareResultByTask(ctx context.Context, task *DataCompareResult) ([]*DataCompareResult, error)
	FindDataCompareResultBySchemaTable(ctx context.Context, task *DataCompareResult) ([]*DataCompareResult, error)
	DeleteDataCompareResult(ctx context.Context, task *DataCompareResult) error
	DeleteDataCompareResultTable(ctx context.Context, task *DataCompareResult) error
	DeleteDataCompareResultName(ctx context.Context, taskName []string) error
}

type IDataCompareSummary 

type IDataCompareSummary interface {
	CreateDataCompareSummary(ctx context.Context, task *DataCompareSummary) (*DataCompareSummary, error)
	GetDataCompareSummary(ctx context.Context, task *DataCompareSummary) (*DataCompareSummary, error)
	UpdateDataCompareSummary(ctx context.Context, task *DataCompareSummary, updates map[string]interface{}) (*DataCompareSummary, error)
	FindDataCompareSummary(ctx context.Context, task *DataCompareSummary) ([]*DataCompareSummary, error)
	DeleteDataCompareSummary(ctx context.Context, task *DataCompareSummary) error
	DeleteDataCompareSummaryName(ctx context.Context, taskName []string) error
	QueryDataCompareSummaryFlag(ctx context.Context, task *DataCompareSummary) ([]*DataCompareSummary, error)
}

type IDataCompareTask 

type IDataCompareTask interface {
	CreateDataCompareTask(ctx context.Context, task *DataCompareTask) (*DataCompareTask, error)
	CreateInBatchDataCompareTask(ctx context.Context, task []*DataCompareTask, thread, batchSize int) error
	UpdateDataCompareTask(ctx context.Context, task *DataCompareTask, updates map[string]interface{}) (*DataCompareTask, error)
	BatchUpdateDataCompareTask(ctx context.Context, task *DataCompareTask, updates map[string]interface{}) (*DataCompareTask, error)
	FindDataCompareTask(ctx context.Context, task *DataCompareTask) ([]*DataCompareTask, error)
	QueryDataCompareTask(ctx context.Context, task *DataCompareTask) ([]*DataCompareTask, error)
	FindDataCompareTaskBySchemaTableChunkStatus(ctx context.Context, task *DataCompareTask) ([]*DataGroupTaskStatusResult, error)
	FindDataCompareTaskGroupByTaskSchemaTable(ctx context.Context, taskName string) ([]*DataGroupChunkResult, error)
	FindDataCompareTaskGroupByTaskSchemaTableStatus(ctx context.Context, taskName string) ([]*DataGroupTaskStatusResult, error)
	FindDataCompareTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)
	QueryDataCompareTaskByTaskStatus(ctx context.Context, task *DataCompareTask) ([]*DataCompareTask, error)
	ListDataCompareTask(ctx context.Context, page uint64, pageSize uint64) ([]*DataCompareTask, error)
	DeleteDataCompareTask(ctx context.Context, task *DataCompareTask) error
	DeleteDataCompareTaskName(ctx context.Context, taskName []string) error
}

type IDataMigrateSummary 

type IDataMigrateSummary interface {
	CreateDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) (*DataMigrateSummary, error)
	GetDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) (*DataMigrateSummary, error)
	UpdateDataMigrateSummary(ctx context.Context, task *DataMigrateSummary, updates map[string]interface{}) (*DataMigrateSummary, error)
	QueryDataMigrateSummaryFlag(ctx context.Context, task *DataMigrateSummary) ([]*DataMigrateSummary, error)
	FindDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) ([]*DataMigrateSummary, error)
	DeleteDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) error
	DeleteDataMigrateSummaryName(ctx context.Context, taskName []string) error
}

type IDataMigrateTask 

type IDataMigrateTask interface {
	CreateDataMigrateTask(ctx context.Context, task *DataMigrateTask) (*DataMigrateTask, error)
	CreateInBatchDataMigrateTask(ctx context.Context, task []*DataMigrateTask, thread, batchSize int) error
	UpdateDataMigrateTask(ctx context.Context, task *DataMigrateTask, updates map[string]interface{}) (*DataMigrateTask, error)
	BatchUpdateDataMigrateTask(ctx context.Context, task *DataMigrateTask, updates map[string]interface{}) (*DataMigrateTask, error)
	GetDataMigrateTask(ctx context.Context, task *DataMigrateTask) (*DataMigrateTask, error)
	FindDataMigrateTask(ctx context.Context, task *DataMigrateTask) ([]*DataMigrateTask, error)
	FindDataMigrateTaskTableStatus(ctx context.Context, taskName, schemaName, tableName string, taskStatus []string) ([]*DataMigrateTask, error)
	QueryDataMigrateTask(ctx context.Context, task *DataMigrateTask) ([]*DataMigrateTask, error)
	FindDataMigrateTaskBySchemaTableChunkStatus(ctx context.Context, task *DataMigrateTask) ([]*DataGroupTaskStatusResult, error)
	FindDataMigrateTaskGroupByTaskSchemaTableStatus(ctx context.Context, taskName string) ([]*DataGroupTaskStatusResult, error)
	FindDataMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)
	ListDataMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*DataMigrateTask, error)
	DeleteDataMigrateTask(ctx context.Context, task *DataMigrateTask) error
	DeleteDataMigrateTaskName(ctx context.Context, taskName []string) error
}

type IDataScanSummary 

type IDataScanSummary interface {
	CreateDataScanSummary(ctx context.Context, task *DataScanSummary) (*DataScanSummary, error)
	GetDataScanSummary(ctx context.Context, task *DataScanSummary) (*DataScanSummary, error)
	UpdateDataScanSummary(ctx context.Context, task *DataScanSummary, updates map[string]interface{}) (*DataScanSummary, error)
	QueryDataScanSummaryFlag(ctx context.Context, task *DataScanSummary) ([]*DataScanSummary, error)
	DeleteDataScanSummary(ctx context.Context, task *DataScanSummary) error
	DeleteDataScanSummaryName(ctx context.Context, taskName []string) error
	FindDataScanSummary(ctx context.Context, task *DataScanSummary) ([]*DataScanSummary, error)
}

type IDataScanTask 

type IDataScanTask interface {
	CreateDataScanTask(ctx context.Context, task *DataScanTask) (*DataScanTask, error)
	CreateInBatchDataScanTask(ctx context.Context, task []*DataScanTask, thread, batchSize int) error
	UpdateDataScanTask(ctx context.Context, task *DataScanTask, updates map[string]interface{}) (*DataScanTask, error)
	BatchUpdateDataScanTask(ctx context.Context, task *DataScanTask, updates map[string]interface{}) (*DataScanTask, error)
	ListDataScanTask(ctx context.Context, page uint64, pageSize uint64) ([]*DataScanTask, error)
	DeleteDataScanTask(ctx context.Context, task *DataScanTask) error
	DeleteDataScanTaskName(ctx context.Context, taskName []string) error
	FindDataScanTask(ctx context.Context, task *DataScanTask) ([]*DataScanTask, error)
	QueryDataScanTask(ctx context.Context, task *DataScanTask) ([]*DataScanTask, error)
	FindDataScanTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)
	FindDataScanTaskGroupByTaskSchemaTable(ctx context.Context, taskName string) ([]*DataGroupChunkResult, error)
	FindDataScanTaskBySchemaTableChunkStatus(ctx context.Context, task *DataScanTask) ([]*DataGroupTaskStatusResult, error)
	QueryDataScanTaskByTaskStatus(ctx context.Context, task *DataScanTask) ([]*DataScanTask, error)
}

type ILog 

type ILog interface {
	CreateLog(ctx context.Context, l *Log) (*Log, error)
	UpdateLog(ctx context.Context, l *Log, updates map[string]interface{}) (*Log, error)
	QueryLog(ctx context.Context, l *Log, last int) ([]*Log, error)
	ListLog(ctx context.Context, page uint64, pageSize uint64) ([]*Log, error)
	DeleteLog(ctx context.Context, taskName []string) error
}

type ISchemaMigrateTask added in v0.0.10 

type ISchemaMigrateTask interface {
	CreateSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) (*SchemaMigrateTask, error)
	GetSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)
	GetSchemaMigrateTaskTable(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)
	UpdateSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask, updates map[string]interface{}) (*SchemaMigrateTask, error)
	BatchUpdateSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask, updates map[string]interface{}) (*SchemaMigrateTask, error)
	FindSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)
	FindSchemaMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)
	BatchFindSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)
	QuerySchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)
	ListSchemaMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*SchemaMigrateTask, error)
	DeleteSchemaMigrateTask(ctx context.Context, id uint64) error
	DeleteSchemaMigrateTaskName(ctx context.Context, taskName []string) error
}

type ISequenceMigrateSummary added in v0.0.13 

type ISequenceMigrateSummary interface {
	CreateSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) (*SequenceMigrateSummary, error)
	GetSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) (*SequenceMigrateSummary, error)
	UpdateSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary, updates map[string]interface{}) (*SequenceMigrateSummary, error)
	FindSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) ([]*SequenceMigrateSummary, error)
	DeleteSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) error
	DeleteSequenceMigrateSummaryName(ctx context.Context, taskName []string) error
}

type ISequenceMigrateTask added in v0.0.10 

type ISequenceMigrateTask interface {
	CreateSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) (*SequenceMigrateTask, error)
	GetSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)
	GetSequenceMigrateTaskTable(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)
	UpdateSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask, updates map[string]interface{}) (*SequenceMigrateTask, error)
	BatchUpdateSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask, updates map[string]interface{}) (*SequenceMigrateTask, error)
	FindSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)
	FindSequenceMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)
	BatchFindSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)
	QuerySequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)
	ListSequenceMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*SequenceMigrateTask, error)
	DeleteSequenceMigrateTask(ctx context.Context, id uint64) error
	DeleteSequenceMigrateTaskName(ctx context.Context, taskName []string) error
}

type ISqlMigrateSummary 

type ISqlMigrateSummary interface {
	CreateSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary) (*SqlMigrateSummary, error)
	GetSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary) (*SqlMigrateSummary, error)
	UpdateSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary, updates map[string]interface{}) (*SqlMigrateSummary, error)
	DeleteSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary) error
	DeleteSqlMigrateSummaryName(ctx context.Context, taskName []string) error
}

type ISqlMigrateTask 

type ISqlMigrateTask interface {
	CreateSqlMigrateTask(ctx context.Context, task *SqlMigrateTask) (*SqlMigrateTask, error)
	CreateInBatchSqlMigrateTask(ctx context.Context, task []*SqlMigrateTask, thread, batchSize int) error
	UpdateSqlMigrateTask(ctx context.Context, task *SqlMigrateTask, updates map[string]interface{}) (*SqlMigrateTask, error)
	BatchUpdateSqlMigrateTask(ctx context.Context, task *SqlMigrateTask, updates map[string]interface{}) (*SqlMigrateTask, error)
	FindSqlMigrateTaskByTaskStatus(ctx context.Context, task *SqlMigrateTask) ([]*SqlMigrateTask, error)
	FindSqlMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)
	ListSqlMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*SqlMigrateTask, error)
	DeleteSqlMigrateTask(ctx context.Context, task *SqlMigrateTask) error
	DeleteSqlMigrateTaskName(ctx context.Context, taskName []string) error
}

type IStructCompareSummary 

type IStructCompareSummary interface {
	CreateStructCompareSummary(ctx context.Context, task *StructCompareSummary) (*StructCompareSummary, error)
	GetStructCompareSummary(ctx context.Context, task *StructCompareSummary) (*StructCompareSummary, error)
	UpdateStructCompareSummary(ctx context.Context, task *StructCompareSummary, updates map[string]interface{}) (*StructCompareSummary, error)
	FindStructCompareSummary(ctx context.Context, task *StructCompareSummary) ([]*StructCompareSummary, error)
	DeleteStructCompareSummary(ctx context.Context, task *StructCompareSummary) error
	DeleteStructCompareSummaryName(ctx context.Context, taskName []string) error
}

type IStructCompareTask 

type IStructCompareTask interface {
	CreateStructCompareTask(ctx context.Context, task *StructCompareTask) (*StructCompareTask, error)
	GetStructCompareTask(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)
	GetStructCompareTaskTable(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)
	UpdateStructCompareTask(ctx context.Context, task *StructCompareTask, updates map[string]interface{}) (*StructCompareTask, error)
	BatchUpdateStructCompareTask(ctx context.Context, task *StructCompareTask, updates map[string]interface{}) (*StructCompareTask, error)
	FindStructCompareTask(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)
	FindStructCompareTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)
	BatchFindStructCompareTask(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)
	ListStructCompareTask(ctx context.Context, page uint64, pageSize uint64) ([]*StructCompareTask, error)
	DeleteStructCompareTask(ctx context.Context, id uint64) error
	DeleteStructCompareTaskName(ctx context.Context, taskName []string) error
}

type IStructMigrateSummary 

type IStructMigrateSummary interface {
	CreateStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) (*StructMigrateSummary, error)
	GetStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) (*StructMigrateSummary, error)
	UpdateStructMigrateSummary(ctx context.Context, task *StructMigrateSummary, updates map[string]interface{}) (*StructMigrateSummary, error)
	FindStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) ([]*StructMigrateSummary, error)
	DeleteStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) error
	DeleteStructMigrateSummaryName(ctx context.Context, taskName []string) error
}

type IStructMigrateTask 

type IStructMigrateTask interface {
	CreateStructMigrateTask(ctx context.Context, task *StructMigrateTask) (*StructMigrateTask, error)
	GetStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)
	GetStructMigrateTaskTable(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)
	UpdateStructMigrateTask(ctx context.Context, task *StructMigrateTask, updates map[string]interface{}) (*StructMigrateTask, error)
	BatchUpdateStructMigrateTask(ctx context.Context, task *StructMigrateTask, updates map[string]interface{}) (*StructMigrateTask, error)
	FindStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)
	FindStructMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)
	BatchFindStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)
	QueryStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)
	ListStructMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*StructMigrateTask, error)
	DeleteStructMigrateTask(ctx context.Context, id uint64) error
	DeleteStructMigrateTaskName(ctx context.Context, taskName []string) error
}

type ITask 

type ITask interface {
	CreateTask(ctx context.Context, task *Task) (*Task, error)
	UpdateTask(ctx context.Context, task *Task, updates map[string]interface{}) (*Task, error)
	GetTask(ctx context.Context, task *Task) (*Task, error)
	ListTask(ctx context.Context, page uint64, pageSize uint64) ([]*Task, error)
	DeleteTask(ctx context.Context, taskName []string) error
}

type Log 

type Log struct {
	ID          uint64 `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName    string `gorm:"type:varchar(30);not null;index:idx_task_name;comment:task name" json:"taskName"`
	SchemaNameS string `gorm:"type:varchar(60);index:schema_table_name;comment:source schema name" json:"schemaNameS"`
	TableNameS  string `gorm:"type:varchar(60);index:schema_table_name;comment:source table name" json:"tableNameS"`
	LogDetail   string `gorm:"type:longtext;comment:task running log" json:"logDetail"`
	*common.Entity
}

type RWAssessMigrateTask 

type RWAssessMigrateTask struct {
	common.GormDB
}

func NewAssessMigrateTaskRW 

func NewAssessMigrateTaskRW(db *gorm.DB) *RWAssessMigrateTask

func (*RWAssessMigrateTask) CreateAssessMigrateTask 

func (rw *RWAssessMigrateTask) CreateAssessMigrateTask(ctx context.Context, task *AssessMigrateTask) (*AssessMigrateTask, error)

func (*RWAssessMigrateTask) DeleteAssessMigrateTask 

func (rw *RWAssessMigrateTask) DeleteAssessMigrateTask(ctx context.Context, taskID uint64) error

func (*RWAssessMigrateTask) DeleteAssessMigrateTaskName 

func (rw *RWAssessMigrateTask) DeleteAssessMigrateTaskName(ctx context.Context, taskName []string) error

func (*RWAssessMigrateTask) GetAssessMigrateTask 

func (rw *RWAssessMigrateTask) GetAssessMigrateTask(ctx context.Context, task *AssessMigrateTask) (*AssessMigrateTask, error)

func (*RWAssessMigrateTask) ListAssessMigrateTask 

func (rw *RWAssessMigrateTask) ListAssessMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*AssessMigrateTask, error)

func (*RWAssessMigrateTask) QueryAssessMigrateTask 

func (rw *RWAssessMigrateTask) QueryAssessMigrateTask(ctx context.Context, task *AssessMigrateTask) ([]*AssessMigrateTask, error)

func (*RWAssessMigrateTask) TableName 

func (rw *RWAssessMigrateTask) TableName(ctx context.Context) string

func (*RWAssessMigrateTask) UpdateAssessMigrateTask 

func (rw *RWAssessMigrateTask) UpdateAssessMigrateTask(ctx context.Context, task *AssessMigrateTask, updates map[string]interface{}) (*AssessMigrateTask, error)

type RWDataCompareResult added in v0.0.6 

type RWDataCompareResult struct {
	common.GormDB
}

func NewDataCompareResultRW added in v0.0.6 

func NewDataCompareResultRW(db *gorm.DB) *RWDataCompareResult

func (*RWDataCompareResult) CreateDataCompareResult added in v0.0.6 

func (rw *RWDataCompareResult) CreateDataCompareResult(ctx context.Context, task *DataCompareResult) (*DataCompareResult, error)

func (*RWDataCompareResult) DeleteDataCompareResult added in v0.0.6 

func (rw *RWDataCompareResult) DeleteDataCompareResult(ctx context.Context, task *DataCompareResult) error

func (*RWDataCompareResult) DeleteDataCompareResultName added in v0.0.6 

func (rw *RWDataCompareResult) DeleteDataCompareResultName(ctx context.Context, taskName []string) error

func (*RWDataCompareResult) DeleteDataCompareResultTable added in v0.0.10 

func (rw *RWDataCompareResult) DeleteDataCompareResultTable(ctx context.Context, task *DataCompareResult) error

func (*RWDataCompareResult) FindDataCompareResultBySchemaTable added in v0.0.14 

func (rw *RWDataCompareResult) FindDataCompareResultBySchemaTable(ctx context.Context, task *DataCompareResult) ([]*DataCompareResult, error)

func (*RWDataCompareResult) FindDataCompareResultByTask added in v0.0.14 

func (rw *RWDataCompareResult) FindDataCompareResultByTask(ctx context.Context, task *DataCompareResult) ([]*DataCompareResult, error)

func (*RWDataCompareResult) TableName added in v0.0.6 

func (rw *RWDataCompareResult) TableName(ctx context.Context) string

type RWDataCompareSummary 

type RWDataCompareSummary struct {
	common.GormDB
}

func NewDataCompareSummaryRW 

func NewDataCompareSummaryRW(db *gorm.DB) *RWDataCompareSummary

func (*RWDataCompareSummary) CreateDataCompareSummary 

func (rw *RWDataCompareSummary) CreateDataCompareSummary(ctx context.Context, task *DataCompareSummary) (*DataCompareSummary, error)

func (*RWDataCompareSummary) DeleteDataCompareSummary 

func (rw *RWDataCompareSummary) DeleteDataCompareSummary(ctx context.Context, task *DataCompareSummary) error

func (*RWDataCompareSummary) DeleteDataCompareSummaryName 

func (rw *RWDataCompareSummary) DeleteDataCompareSummaryName(ctx context.Context, taskName []string) error

func (*RWDataCompareSummary) FindDataCompareSummary 

func (rw *RWDataCompareSummary) FindDataCompareSummary(ctx context.Context, task *DataCompareSummary) ([]*DataCompareSummary, error)

func (*RWDataCompareSummary) GetDataCompareSummary 

func (rw *RWDataCompareSummary) GetDataCompareSummary(ctx context.Context, task *DataCompareSummary) (*DataCompareSummary, error)

func (*RWDataCompareSummary) QueryDataCompareSummaryFlag added in v0.0.11 

func (rw *RWDataCompareSummary) QueryDataCompareSummaryFlag(ctx context.Context, task *DataCompareSummary) ([]*DataCompareSummary, error)

func (*RWDataCompareSummary) TableName 

func (rw *RWDataCompareSummary) TableName(ctx context.Context) string

func (*RWDataCompareSummary) UpdateDataCompareSummary 

func (rw *RWDataCompareSummary) UpdateDataCompareSummary(ctx context.Context, task *DataCompareSummary, updates map[string]interface{}) (*DataCompareSummary, error)

type RWDataCompareTask 

type RWDataCompareTask struct {
	common.GormDB
}

func NewDataCompareTaskRW 

func NewDataCompareTaskRW(db *gorm.DB) *RWDataCompareTask

func (*RWDataCompareTask) BatchUpdateDataCompareTask 

func (rw *RWDataCompareTask) BatchUpdateDataCompareTask(ctx context.Context, task *DataCompareTask, updates map[string]interface{}) (*DataCompareTask, error)

func (*RWDataCompareTask) CreateDataCompareTask 

func (rw *RWDataCompareTask) CreateDataCompareTask(ctx context.Context, task *DataCompareTask) (*DataCompareTask, error)

func (*RWDataCompareTask) CreateInBatchDataCompareTask 

func (rw *RWDataCompareTask) CreateInBatchDataCompareTask(ctx context.Context, task []*DataCompareTask, thread, batchSize int) error

func (*RWDataCompareTask) DeleteDataCompareTask 

func (rw *RWDataCompareTask) DeleteDataCompareTask(ctx context.Context, task *DataCompareTask) error

func (*RWDataCompareTask) DeleteDataCompareTaskName 

func (rw *RWDataCompareTask) DeleteDataCompareTaskName(ctx context.Context, taskName []string) error

func (*RWDataCompareTask) FindDataCompareTask 

func (rw *RWDataCompareTask) FindDataCompareTask(ctx context.Context, task *DataCompareTask) ([]*DataCompareTask, error)

func (*RWDataCompareTask) FindDataCompareTaskBySchemaTableChunkStatus 

func (rw *RWDataCompareTask) FindDataCompareTaskBySchemaTableChunkStatus(ctx context.Context, task *DataCompareTask) ([]*DataGroupTaskStatusResult, error)

func (*RWDataCompareTask) FindDataCompareTaskGroupByTaskSchemaTable 

func (rw *RWDataCompareTask) FindDataCompareTaskGroupByTaskSchemaTable(ctx context.Context, taskName string) ([]*DataGroupChunkResult, error)

func (*RWDataCompareTask) FindDataCompareTaskGroupByTaskSchemaTableStatus 

func (rw *RWDataCompareTask) FindDataCompareTaskGroupByTaskSchemaTableStatus(ctx context.Context, taskName string) ([]*DataGroupTaskStatusResult, error)

func (*RWDataCompareTask) FindDataCompareTaskGroupByTaskStatus 

func (rw *RWDataCompareTask) FindDataCompareTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)

func (*RWDataCompareTask) ListDataCompareTask 

func (rw *RWDataCompareTask) ListDataCompareTask(ctx context.Context, page uint64, pageSize uint64) ([]*DataCompareTask, error)

func (*RWDataCompareTask) QueryDataCompareTask added in v0.0.7 

func (rw *RWDataCompareTask) QueryDataCompareTask(ctx context.Context, task *DataCompareTask) ([]*DataCompareTask, error)

func (*RWDataCompareTask) QueryDataCompareTaskByTaskStatus 

func (rw *RWDataCompareTask) QueryDataCompareTaskByTaskStatus(ctx context.Context, task *DataCompareTask) ([]*DataCompareTask, error)

func (*RWDataCompareTask) TableName 

func (rw *RWDataCompareTask) TableName(ctx context.Context) string

func (*RWDataCompareTask) UpdateDataCompareTask 

func (rw *RWDataCompareTask) UpdateDataCompareTask(ctx context.Context, task *DataCompareTask, updates map[string]interface{}) (*DataCompareTask, error)

type RWDataMigrateSummary 

type RWDataMigrateSummary struct {
	common.GormDB
}

func NewDataMigrateSummaryRW 

func NewDataMigrateSummaryRW(db *gorm.DB) *RWDataMigrateSummary

func (*RWDataMigrateSummary) CreateDataMigrateSummary 

func (rw *RWDataMigrateSummary) CreateDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) (*DataMigrateSummary, error)

func (*RWDataMigrateSummary) DeleteDataMigrateSummary 

func (rw *RWDataMigrateSummary) DeleteDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) error

func (*RWDataMigrateSummary) DeleteDataMigrateSummaryName 

func (rw *RWDataMigrateSummary) DeleteDataMigrateSummaryName(ctx context.Context, taskName []string) error

func (*RWDataMigrateSummary) FindDataMigrateSummary 

func (rw *RWDataMigrateSummary) FindDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) ([]*DataMigrateSummary, error)

func (*RWDataMigrateSummary) GetDataMigrateSummary 

func (rw *RWDataMigrateSummary) GetDataMigrateSummary(ctx context.Context, task *DataMigrateSummary) (*DataMigrateSummary, error)

func (*RWDataMigrateSummary) QueryDataMigrateSummaryFlag added in v0.0.11 

func (rw *RWDataMigrateSummary) QueryDataMigrateSummaryFlag(ctx context.Context, task *DataMigrateSummary) ([]*DataMigrateSummary, error)

func (*RWDataMigrateSummary) TableName 

func (rw *RWDataMigrateSummary) TableName(ctx context.Context) string

func (*RWDataMigrateSummary) UpdateDataMigrateSummary 

func (rw *RWDataMigrateSummary) UpdateDataMigrateSummary(ctx context.Context, task *DataMigrateSummary, updates map[string]interface{}) (*DataMigrateSummary, error)

type RWDataMigrateTask 

type RWDataMigrateTask struct {
	common.GormDB
}

func NewDataMigrateTaskRW 

func NewDataMigrateTaskRW(db *gorm.DB) *RWDataMigrateTask

func (*RWDataMigrateTask) BatchUpdateDataMigrateTask 

func (rw *RWDataMigrateTask) BatchUpdateDataMigrateTask(ctx context.Context, task *DataMigrateTask, updates map[string]interface{}) (*DataMigrateTask, error)

func (*RWDataMigrateTask) CreateDataMigrateTask 

func (rw *RWDataMigrateTask) CreateDataMigrateTask(ctx context.Context, task *DataMigrateTask) (*DataMigrateTask, error)

func (*RWDataMigrateTask) CreateInBatchDataMigrateTask 

func (rw *RWDataMigrateTask) CreateInBatchDataMigrateTask(ctx context.Context, task []*DataMigrateTask, thread, batchSize int) error

func (*RWDataMigrateTask) DeleteDataMigrateTask 

func (rw *RWDataMigrateTask) DeleteDataMigrateTask(ctx context.Context, task *DataMigrateTask) error

func (*RWDataMigrateTask) DeleteDataMigrateTaskName 

func (rw *RWDataMigrateTask) DeleteDataMigrateTaskName(ctx context.Context, taskName []string) error

func (*RWDataMigrateTask) FindDataMigrateTask 

func (rw *RWDataMigrateTask) FindDataMigrateTask(ctx context.Context, task *DataMigrateTask) ([]*DataMigrateTask, error)

func (*RWDataMigrateTask) FindDataMigrateTaskBySchemaTableChunkStatus 

func (rw *RWDataMigrateTask) FindDataMigrateTaskBySchemaTableChunkStatus(ctx context.Context, task *DataMigrateTask) ([]*DataGroupTaskStatusResult, error)

func (*RWDataMigrateTask) FindDataMigrateTaskGroupByTaskSchemaTableStatus 

func (rw *RWDataMigrateTask) FindDataMigrateTaskGroupByTaskSchemaTableStatus(ctx context.Context, taskName string) ([]*DataGroupTaskStatusResult, error)

func (*RWDataMigrateTask) FindDataMigrateTaskGroupByTaskStatus 

func (rw *RWDataMigrateTask) FindDataMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)

func (*RWDataMigrateTask) FindDataMigrateTaskTableStatus added in v0.0.9 

func (rw *RWDataMigrateTask) FindDataMigrateTaskTableStatus(ctx context.Context, taskName, schemaName, tableName string, taskStatus []string) ([]*DataMigrateTask, error)

func (*RWDataMigrateTask) GetDataMigrateTask 

func (rw *RWDataMigrateTask) GetDataMigrateTask(ctx context.Context, task *DataMigrateTask) (*DataMigrateTask, error)

func (*RWDataMigrateTask) ListDataMigrateTask 

func (rw *RWDataMigrateTask) ListDataMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*DataMigrateTask, error)

func (*RWDataMigrateTask) QueryDataMigrateTask added in v0.0.7 

func (rw *RWDataMigrateTask) QueryDataMigrateTask(ctx context.Context, task *DataMigrateTask) ([]*DataMigrateTask, error)

func (*RWDataMigrateTask) TableName 

func (rw *RWDataMigrateTask) TableName(ctx context.Context) string

func (*RWDataMigrateTask) UpdateDataMigrateTask 

func (rw *RWDataMigrateTask) UpdateDataMigrateTask(ctx context.Context, task *DataMigrateTask, updates map[string]interface{}) (*DataMigrateTask, error)

type RWDataScanSummary 

type RWDataScanSummary struct {
	common.GormDB
}

func NewDataScanSummaryRW 

func NewDataScanSummaryRW(db *gorm.DB) *RWDataScanSummary

func (*RWDataScanSummary) CreateDataScanSummary 

func (rw *RWDataScanSummary) CreateDataScanSummary(ctx context.Context, task *DataScanSummary) (*DataScanSummary, error)

func (*RWDataScanSummary) DeleteDataScanSummary 

func (rw *RWDataScanSummary) DeleteDataScanSummary(ctx context.Context, task *DataScanSummary) error

func (*RWDataScanSummary) DeleteDataScanSummaryName 

func (rw *RWDataScanSummary) DeleteDataScanSummaryName(ctx context.Context, taskName []string) error

func (*RWDataScanSummary) FindDataScanSummary 

func (rw *RWDataScanSummary) FindDataScanSummary(ctx context.Context, task *DataScanSummary) ([]*DataScanSummary, error)

func (*RWDataScanSummary) GetDataScanSummary 

func (rw *RWDataScanSummary) GetDataScanSummary(ctx context.Context, task *DataScanSummary) (*DataScanSummary, error)

func (*RWDataScanSummary) QueryDataScanSummaryFlag added in v0.0.11 

func (rw *RWDataScanSummary) QueryDataScanSummaryFlag(ctx context.Context, task *DataScanSummary) ([]*DataScanSummary, error)

func (*RWDataScanSummary) TableName 

func (rw *RWDataScanSummary) TableName(ctx context.Context) string

func (*RWDataScanSummary) UpdateDataScanSummary 

func (rw *RWDataScanSummary) UpdateDataScanSummary(ctx context.Context, task *DataScanSummary, updates map[string]interface{}) (*DataScanSummary, error)

type RWDataScanTask 

type RWDataScanTask struct {
	common.GormDB
}

func NewDataScanTaskRW 

func NewDataScanTaskRW(db *gorm.DB) *RWDataScanTask

func (*RWDataScanTask) BatchUpdateDataScanTask 

func (rw *RWDataScanTask) BatchUpdateDataScanTask(ctx context.Context, task *DataScanTask, updates map[string]interface{}) (*DataScanTask, error)

func (*RWDataScanTask) CreateDataScanTask 

func (rw *RWDataScanTask) CreateDataScanTask(ctx context.Context, task *DataScanTask) (*DataScanTask, error)

func (*RWDataScanTask) CreateInBatchDataScanTask 

func (rw *RWDataScanTask) CreateInBatchDataScanTask(ctx context.Context, task []*DataScanTask, thread, batchSize int) error

func (*RWDataScanTask) DeleteDataScanTask 

func (rw *RWDataScanTask) DeleteDataScanTask(ctx context.Context, task *DataScanTask) error

func (*RWDataScanTask) DeleteDataScanTaskName 

func (rw *RWDataScanTask) DeleteDataScanTaskName(ctx context.Context, taskName []string) error

func (*RWDataScanTask) FindDataScanTask 

func (rw *RWDataScanTask) FindDataScanTask(ctx context.Context, task *DataScanTask) ([]*DataScanTask, error)

func (*RWDataScanTask) FindDataScanTaskBySchemaTableChunkStatus 

func (rw *RWDataScanTask) FindDataScanTaskBySchemaTableChunkStatus(ctx context.Context, task *DataScanTask) ([]*DataGroupTaskStatusResult, error)

func (*RWDataScanTask) FindDataScanTaskGroupByTaskSchemaTable 

func (rw *RWDataScanTask) FindDataScanTaskGroupByTaskSchemaTable(ctx context.Context, taskName string) ([]*DataGroupChunkResult, error)

func (*RWDataScanTask) FindDataScanTaskGroupByTaskStatus 

func (rw *RWDataScanTask) FindDataScanTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)

func (*RWDataScanTask) ListDataScanTask 

func (rw *RWDataScanTask) ListDataScanTask(ctx context.Context, page uint64, pageSize uint64) ([]*DataScanTask, error)

func (*RWDataScanTask) QueryDataScanTask added in v0.0.7 

func (rw *RWDataScanTask) QueryDataScanTask(ctx context.Context, task *DataScanTask) ([]*DataScanTask, error)

func (*RWDataScanTask) QueryDataScanTaskByTaskStatus 

func (rw *RWDataScanTask) QueryDataScanTaskByTaskStatus(ctx context.Context, task *DataScanTask) ([]*DataScanTask, error)

func (*RWDataScanTask) TableName 

func (rw *RWDataScanTask) TableName(ctx context.Context) string

func (*RWDataScanTask) UpdateDataScanTask 

func (rw *RWDataScanTask) UpdateDataScanTask(ctx context.Context, task *DataScanTask, updates map[string]interface{}) (*DataScanTask, error)

type RWLog 

type RWLog struct {
	common.GormDB
}

func NewLogRW 

func NewLogRW(db *gorm.DB) *RWLog

func (*RWLog) CreateLog 

func (rw *RWLog) CreateLog(ctx context.Context, task *Log) (*Log, error)

func (*RWLog) DeleteLog 

func (rw *RWLog) DeleteLog(ctx context.Context, taskName []string) error

func (*RWLog) ListLog 

func (rw *RWLog) ListLog(ctx context.Context, page uint64, pageSize uint64) ([]*Log, error)

func (*RWLog) QueryLog 

func (rw *RWLog) QueryLog(ctx context.Context, task *Log, last int) ([]*Log, error)

func (*RWLog) TableName 

func (rw *RWLog) TableName(ctx context.Context) string

func (*RWLog) UpdateLog 

func (rw *RWLog) UpdateLog(ctx context.Context, task *Log, updates map[string]interface{}) (*Log, error)

type RWSchemaMigrateTask added in v0.0.10 

type RWSchemaMigrateTask struct {
	common.GormDB
}

func NewSchemaMigrateTaskRW added in v0.0.10 

func NewSchemaMigrateTaskRW(db *gorm.DB) *RWSchemaMigrateTask

func (*RWSchemaMigrateTask) BatchFindSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) BatchFindSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) BatchUpdateSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) BatchUpdateSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask, updates map[string]interface{}) (*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) CreateSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) CreateSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) (*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) DeleteSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) DeleteSchemaMigrateTask(ctx context.Context, taskID uint64) error

func (*RWSchemaMigrateTask) DeleteSchemaMigrateTaskName added in v0.0.10 

func (rw *RWSchemaMigrateTask) DeleteSchemaMigrateTaskName(ctx context.Context, taskName []string) error

func (*RWSchemaMigrateTask) FindSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) FindSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) FindSchemaMigrateTaskGroupByTaskStatus added in v0.0.10 

func (rw *RWSchemaMigrateTask) FindSchemaMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)

func (*RWSchemaMigrateTask) GetSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) GetSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) GetSchemaMigrateTaskTable added in v0.0.10 

func (rw *RWSchemaMigrateTask) GetSchemaMigrateTaskTable(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) ListSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) ListSchemaMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) QuerySchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) QuerySchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask) ([]*SchemaMigrateTask, error)

func (*RWSchemaMigrateTask) TableName added in v0.0.10 

func (rw *RWSchemaMigrateTask) TableName(ctx context.Context) string

func (*RWSchemaMigrateTask) UpdateSchemaMigrateTask added in v0.0.10 

func (rw *RWSchemaMigrateTask) UpdateSchemaMigrateTask(ctx context.Context, task *SchemaMigrateTask, updates map[string]interface{}) (*SchemaMigrateTask, error)

type RWSequenceMigrateSummary added in v0.0.13 

type RWSequenceMigrateSummary struct {
	common.GormDB
}

func NewSequenceMigrateSummaryRW added in v0.0.13 

func NewSequenceMigrateSummaryRW(db *gorm.DB) *RWSequenceMigrateSummary

func (*RWSequenceMigrateSummary) CreateSequenceMigrateSummary added in v0.0.13 

func (rw *RWSequenceMigrateSummary) CreateSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) (*SequenceMigrateSummary, error)

func (*RWSequenceMigrateSummary) DeleteSequenceMigrateSummary added in v0.0.13 

func (rw *RWSequenceMigrateSummary) DeleteSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) error

func (*RWSequenceMigrateSummary) DeleteSequenceMigrateSummaryName added in v0.0.13 

func (rw *RWSequenceMigrateSummary) DeleteSequenceMigrateSummaryName(ctx context.Context, taskName []string) error

func (*RWSequenceMigrateSummary) FindSequenceMigrateSummary added in v0.0.13 

func (rw *RWSequenceMigrateSummary) FindSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) ([]*SequenceMigrateSummary, error)

func (*RWSequenceMigrateSummary) GetSequenceMigrateSummary added in v0.0.13 

func (rw *RWSequenceMigrateSummary) GetSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary) (*SequenceMigrateSummary, error)

func (*RWSequenceMigrateSummary) TableName added in v0.0.13 

func (rw *RWSequenceMigrateSummary) TableName(ctx context.Context) string

func (*RWSequenceMigrateSummary) UpdateSequenceMigrateSummary added in v0.0.13 

func (rw *RWSequenceMigrateSummary) UpdateSequenceMigrateSummary(ctx context.Context, task *SequenceMigrateSummary, updates map[string]interface{}) (*SequenceMigrateSummary, error)

type RWSequenceMigrateTask added in v0.0.10 

type RWSequenceMigrateTask struct {
	common.GormDB
}

func NewSequenceMigrateTaskRW added in v0.0.10 

func NewSequenceMigrateTaskRW(db *gorm.DB) *RWSequenceMigrateTask

func (*RWSequenceMigrateTask) BatchFindSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) BatchFindSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) BatchUpdateSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) BatchUpdateSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask, updates map[string]interface{}) (*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) CreateSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) CreateSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) (*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) DeleteSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) DeleteSequenceMigrateTask(ctx context.Context, taskID uint64) error

func (*RWSequenceMigrateTask) DeleteSequenceMigrateTaskName added in v0.0.10 

func (rw *RWSequenceMigrateTask) DeleteSequenceMigrateTaskName(ctx context.Context, taskName []string) error

func (*RWSequenceMigrateTask) FindSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) FindSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) FindSequenceMigrateTaskGroupByTaskStatus added in v0.0.10 

func (rw *RWSequenceMigrateTask) FindSequenceMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)

func (*RWSequenceMigrateTask) GetSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) GetSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) GetSequenceMigrateTaskTable added in v0.0.10 

func (rw *RWSequenceMigrateTask) GetSequenceMigrateTaskTable(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) ListSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) ListSequenceMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) QuerySequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) QuerySequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask) ([]*SequenceMigrateTask, error)

func (*RWSequenceMigrateTask) TableName added in v0.0.10 

func (rw *RWSequenceMigrateTask) TableName(ctx context.Context) string

func (*RWSequenceMigrateTask) UpdateSequenceMigrateTask added in v0.0.10 

func (rw *RWSequenceMigrateTask) UpdateSequenceMigrateTask(ctx context.Context, task *SequenceMigrateTask, updates map[string]interface{}) (*SequenceMigrateTask, error)

type RWSqlMigrateSummary 

type RWSqlMigrateSummary struct {
	common.GormDB
}

func NewSqlMigrateSummaryRW 

func NewSqlMigrateSummaryRW(db *gorm.DB) *RWSqlMigrateSummary

func (*RWSqlMigrateSummary) CreateSqlMigrateSummary 

func (rw *RWSqlMigrateSummary) CreateSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary) (*SqlMigrateSummary, error)

func (*RWSqlMigrateSummary) DeleteSqlMigrateSummary 

func (rw *RWSqlMigrateSummary) DeleteSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary) error

func (*RWSqlMigrateSummary) DeleteSqlMigrateSummaryName 

func (rw *RWSqlMigrateSummary) DeleteSqlMigrateSummaryName(ctx context.Context, taskName []string) error

func (*RWSqlMigrateSummary) GetSqlMigrateSummary 

func (rw *RWSqlMigrateSummary) GetSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary) (*SqlMigrateSummary, error)

func (*RWSqlMigrateSummary) TableName 

func (rw *RWSqlMigrateSummary) TableName(ctx context.Context) string

func (*RWSqlMigrateSummary) UpdateSqlMigrateSummary 

func (rw *RWSqlMigrateSummary) UpdateSqlMigrateSummary(ctx context.Context, task *SqlMigrateSummary, updates map[string]interface{}) (*SqlMigrateSummary, error)

type RWSqlMigrateTask 

type RWSqlMigrateTask struct {
	common.GormDB
}

func NewSqlMigrateTaskRW 

func NewSqlMigrateTaskRW(db *gorm.DB) *RWSqlMigrateTask

func (*RWSqlMigrateTask) BatchUpdateSqlMigrateTask 

func (rw *RWSqlMigrateTask) BatchUpdateSqlMigrateTask(ctx context.Context, task *SqlMigrateTask, updates map[string]interface{}) (*SqlMigrateTask, error)

func (*RWSqlMigrateTask) CreateInBatchSqlMigrateTask 

func (rw *RWSqlMigrateTask) CreateInBatchSqlMigrateTask(ctx context.Context, task []*SqlMigrateTask, thread, batchSize int) error

func (*RWSqlMigrateTask) CreateSqlMigrateTask 

func (rw *RWSqlMigrateTask) CreateSqlMigrateTask(ctx context.Context, task *SqlMigrateTask) (*SqlMigrateTask, error)

func (*RWSqlMigrateTask) DeleteSqlMigrateTask 

func (rw *RWSqlMigrateTask) DeleteSqlMigrateTask(ctx context.Context, task *SqlMigrateTask) error

func (*RWSqlMigrateTask) DeleteSqlMigrateTaskName 

func (rw *RWSqlMigrateTask) DeleteSqlMigrateTaskName(ctx context.Context, taskName []string) error

func (*RWSqlMigrateTask) FindSqlMigrateTaskByTaskStatus 

func (rw *RWSqlMigrateTask) FindSqlMigrateTaskByTaskStatus(ctx context.Context, task *SqlMigrateTask) ([]*SqlMigrateTask, error)

func (*RWSqlMigrateTask) FindSqlMigrateTaskGroupByTaskStatus 

func (rw *RWSqlMigrateTask) FindSqlMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*DataGroupStatusResult, error)

func (*RWSqlMigrateTask) ListSqlMigrateTask 

func (rw *RWSqlMigrateTask) ListSqlMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*SqlMigrateTask, error)

func (*RWSqlMigrateTask) TableName 

func (rw *RWSqlMigrateTask) TableName(ctx context.Context) string

func (*RWSqlMigrateTask) UpdateSqlMigrateTask 

func (rw *RWSqlMigrateTask) UpdateSqlMigrateTask(ctx context.Context, task *SqlMigrateTask, updates map[string]interface{}) (*SqlMigrateTask, error)

type RWStructCompareSummary 

type RWStructCompareSummary struct {
	common.GormDB
}

func NewStructCompareSummaryRW 

func NewStructCompareSummaryRW(db *gorm.DB) *RWStructCompareSummary

func (*RWStructCompareSummary) CreateStructCompareSummary 

func (rw *RWStructCompareSummary) CreateStructCompareSummary(ctx context.Context, task *StructCompareSummary) (*StructCompareSummary, error)

func (*RWStructCompareSummary) DeleteStructCompareSummary 

func (rw *RWStructCompareSummary) DeleteStructCompareSummary(ctx context.Context, task *StructCompareSummary) error

func (*RWStructCompareSummary) DeleteStructCompareSummaryName 

func (rw *RWStructCompareSummary) DeleteStructCompareSummaryName(ctx context.Context, taskName []string) error

func (*RWStructCompareSummary) FindStructCompareSummary 

func (rw *RWStructCompareSummary) FindStructCompareSummary(ctx context.Context, task *StructCompareSummary) ([]*StructCompareSummary, error)

func (*RWStructCompareSummary) GetStructCompareSummary 

func (rw *RWStructCompareSummary) GetStructCompareSummary(ctx context.Context, task *StructCompareSummary) (*StructCompareSummary, error)

func (*RWStructCompareSummary) TableName 

func (rw *RWStructCompareSummary) TableName(ctx context.Context) string

func (*RWStructCompareSummary) UpdateStructCompareSummary 

func (rw *RWStructCompareSummary) UpdateStructCompareSummary(ctx context.Context, task *StructCompareSummary, updates map[string]interface{}) (*StructCompareSummary, error)

type RWStructCompareTask 

type RWStructCompareTask struct {
	common.GormDB
}

func NewStructCompareTaskRW 

func NewStructCompareTaskRW(db *gorm.DB) *RWStructCompareTask

func (*RWStructCompareTask) BatchFindStructCompareTask 

func (rw *RWStructCompareTask) BatchFindStructCompareTask(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)

func (*RWStructCompareTask) BatchUpdateStructCompareTask 

func (rw *RWStructCompareTask) BatchUpdateStructCompareTask(ctx context.Context, task *StructCompareTask, updates map[string]interface{}) (*StructCompareTask, error)

func (*RWStructCompareTask) CreateStructCompareTask 

func (rw *RWStructCompareTask) CreateStructCompareTask(ctx context.Context, task *StructCompareTask) (*StructCompareTask, error)

func (*RWStructCompareTask) DeleteStructCompareTask 

func (rw *RWStructCompareTask) DeleteStructCompareTask(ctx context.Context, taskID uint64) error

func (*RWStructCompareTask) DeleteStructCompareTaskName 

func (rw *RWStructCompareTask) DeleteStructCompareTaskName(ctx context.Context, taskName []string) error

func (*RWStructCompareTask) FindStructCompareTask 

func (rw *RWStructCompareTask) FindStructCompareTask(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)

func (*RWStructCompareTask) FindStructCompareTaskGroupByTaskStatus 

func (rw *RWStructCompareTask) FindStructCompareTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)

func (*RWStructCompareTask) GetStructCompareTask 

func (rw *RWStructCompareTask) GetStructCompareTask(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)

func (*RWStructCompareTask) GetStructCompareTaskTable 

func (rw *RWStructCompareTask) GetStructCompareTaskTable(ctx context.Context, task *StructCompareTask) ([]*StructCompareTask, error)

func (*RWStructCompareTask) ListStructCompareTask 

func (rw *RWStructCompareTask) ListStructCompareTask(ctx context.Context, page uint64, pageSize uint64) ([]*StructCompareTask, error)

func (*RWStructCompareTask) TableName 

func (rw *RWStructCompareTask) TableName(ctx context.Context) string

func (*RWStructCompareTask) UpdateStructCompareTask 

func (rw *RWStructCompareTask) UpdateStructCompareTask(ctx context.Context, task *StructCompareTask, updates map[string]interface{}) (*StructCompareTask, error)

type RWStructMigrateSummary 

type RWStructMigrateSummary struct {
	common.GormDB
}

func NewStructMigrateSummaryRW 

func NewStructMigrateSummaryRW(db *gorm.DB) *RWStructMigrateSummary

func (*RWStructMigrateSummary) CreateStructMigrateSummary 

func (rw *RWStructMigrateSummary) CreateStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) (*StructMigrateSummary, error)

func (*RWStructMigrateSummary) DeleteStructMigrateSummary 

func (rw *RWStructMigrateSummary) DeleteStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) error

func (*RWStructMigrateSummary) DeleteStructMigrateSummaryName 

func (rw *RWStructMigrateSummary) DeleteStructMigrateSummaryName(ctx context.Context, taskName []string) error

func (*RWStructMigrateSummary) FindStructMigrateSummary 

func (rw *RWStructMigrateSummary) FindStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) ([]*StructMigrateSummary, error)

func (*RWStructMigrateSummary) GetStructMigrateSummary 

func (rw *RWStructMigrateSummary) GetStructMigrateSummary(ctx context.Context, task *StructMigrateSummary) (*StructMigrateSummary, error)

func (*RWStructMigrateSummary) TableName 

func (rw *RWStructMigrateSummary) TableName(ctx context.Context) string

func (*RWStructMigrateSummary) UpdateStructMigrateSummary 

func (rw *RWStructMigrateSummary) UpdateStructMigrateSummary(ctx context.Context, task *StructMigrateSummary, updates map[string]interface{}) (*StructMigrateSummary, error)

type RWStructMigrateTask 

type RWStructMigrateTask struct {
	common.GormDB
}

func NewStructMigrateTaskRW 

func NewStructMigrateTaskRW(db *gorm.DB) *RWStructMigrateTask

func (*RWStructMigrateTask) BatchFindStructMigrateTask 

func (rw *RWStructMigrateTask) BatchFindStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)

func (*RWStructMigrateTask) BatchUpdateStructMigrateTask 

func (rw *RWStructMigrateTask) BatchUpdateStructMigrateTask(ctx context.Context, task *StructMigrateTask, updates map[string]interface{}) (*StructMigrateTask, error)

func (*RWStructMigrateTask) CreateStructMigrateTask 

func (rw *RWStructMigrateTask) CreateStructMigrateTask(ctx context.Context, task *StructMigrateTask) (*StructMigrateTask, error)

func (*RWStructMigrateTask) DeleteStructMigrateTask 

func (rw *RWStructMigrateTask) DeleteStructMigrateTask(ctx context.Context, taskID uint64) error

func (*RWStructMigrateTask) DeleteStructMigrateTaskName 

func (rw *RWStructMigrateTask) DeleteStructMigrateTaskName(ctx context.Context, taskName []string) error

func (*RWStructMigrateTask) FindStructMigrateTask 

func (rw *RWStructMigrateTask) FindStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)

func (*RWStructMigrateTask) FindStructMigrateTaskGroupByTaskStatus 

func (rw *RWStructMigrateTask) FindStructMigrateTaskGroupByTaskStatus(ctx context.Context, taskName string) ([]*StructGroupStatusResult, error)

func (*RWStructMigrateTask) GetStructMigrateTask 

func (rw *RWStructMigrateTask) GetStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)

func (*RWStructMigrateTask) GetStructMigrateTaskTable 

func (rw *RWStructMigrateTask) GetStructMigrateTaskTable(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)

func (*RWStructMigrateTask) ListStructMigrateTask 

func (rw *RWStructMigrateTask) ListStructMigrateTask(ctx context.Context, page uint64, pageSize uint64) ([]*StructMigrateTask, error)

func (*RWStructMigrateTask) QueryStructMigrateTask 

func (rw *RWStructMigrateTask) QueryStructMigrateTask(ctx context.Context, task *StructMigrateTask) ([]*StructMigrateTask, error)

func (*RWStructMigrateTask) TableName 

func (rw *RWStructMigrateTask) TableName(ctx context.Context) string

func (*RWStructMigrateTask) UpdateStructMigrateTask 

func (rw *RWStructMigrateTask) UpdateStructMigrateTask(ctx context.Context, task *StructMigrateTask, updates map[string]interface{}) (*StructMigrateTask, error)

type RWTask 

type RWTask struct {
	common.GormDB
}

func NewTaskRW 

func NewTaskRW(db *gorm.DB) *RWTask

func (*RWTask) CreateTask 

func (rw *RWTask) CreateTask(ctx context.Context, task *Task) (*Task, error)

func (*RWTask) DeleteTask 

func (rw *RWTask) DeleteTask(ctx context.Context, taskName []string) error

func (*RWTask) GetTask 

func (rw *RWTask) GetTask(ctx context.Context, task *Task) (*Task, error)

func (*RWTask) ListTask 

func (rw *RWTask) ListTask(ctx context.Context, page uint64, pageSize uint64) ([]*Task, error)

func (*RWTask) TableName 

func (rw *RWTask) TableName(ctx context.Context) string

func (*RWTask) UpdateTask 

func (rw *RWTask) UpdateTask(ctx context.Context, task *Task, updates map[string]interface{}) (*Task, error)

type SchemaMigrateTask added in v0.0.10 

type SchemaMigrateTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `gorm:"type:varchar(30);not null;uniqueIndex:uniq_task_schema_name;index:idx_task_name;comment:task name" json:"taskName"`
	SchemaNameS     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_task_schema_name;comment:source schema name" json:"schemaNameS"`
	SchemaNameT     string  `gorm:"type:varchar(60);comment:target schema name" json:"schemaNameT"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	TargetSqlDigest string  `gorm:"type:longtext;comment:target sql digest" json:"targetSqlDigest"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
}

type SequenceMigrateSummary added in v0.0.13 

type SequenceMigrateSummary struct {
	ID          uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName    string  `` /* 127-byte string literal not displayed */
	SchemaNameS string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_seq_name_complex;comment:source schema name" json:"schemaNameS"`
	SeqTotals   uint64  `gorm:"type:int;comment:source seq seq totals" json:"seqTotals"`
	SeqSuccess  uint64  `gorm:"type:int;comment:source seq seq success" json:"seqSuccess"`
	SeqFails    uint64  `gorm:"type:int;comment:source seq seq fails" json:"seqFails"`
	SeqWaits    uint64  `gorm:"type:int;comment:source seq seq waits" json:"seqWaits"`
	SeqRuns     uint64  `gorm:"type:int;comment:source seq seq runs" json:"seqRuns"`
	SeqStops    uint64  `gorm:"type:int;comment:source seq seq stops" json:"seqStops"`
	InitFlag    string  `gorm:"type:char(1);default:N;comment:the task seq init flag" json:"initFlag"`
	MigrateFlag string  `gorm:"type:char(1);default:N;comment:the task seq migrate finished flag" json:"migrateFlag"`
	Duration    float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type SequenceMigrateTask added in v0.0.10 

type SequenceMigrateTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `gorm:"type:varchar(30);not null;uniqueIndex:uniq_schema_sequence_name;index:idx_task_name;comment:task name" json:"taskName"`
	SchemaNameS     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_sequence_name;comment:source schema name" json:"schemaNameS"`
	SequenceNameS   string  `gorm:"type:varchar(60);uniqueIndex:uniq_schema_sequence_name;comment:source sequence name" json:"tableNameS"`
	SchemaNameT     string  `gorm:"type:varchar(60);comment:target schema name" json:"schemaNameT"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	SourceSqlDigest string  `gorm:"type:longtext;comment:origin sql digest" json:"sourceSqlDigest"`
	TargetSqlDigest string  `gorm:"type:longtext;comment:target sql digest" json:"targetSqlDigest"`
	IsCompatible    string  `gorm:"type:varchar(1);comment:sql digest compatible" json:"isCompatible"`
	ErrorDetail     string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type SqlMigrateSummary 

type SqlMigrateSummary struct {
	ID          uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName    string  `gorm:"type:varchar(30);not null;uniqueIndex:uniq_schema_table_complex;comment:task name" json:"taskName"`
	SqlTotals   uint64  `gorm:"type:int;comment:source table sql totals" json:"sqlTotals"`
	SqlSuccess  uint64  `gorm:"type:int;comment:source table sql success" json:"sqlSuccess"`
	SqlFails    uint64  `gorm:"type:int;comment:source table sql fails" json:"sqlFails"`
	SqlWaits    uint64  `gorm:"type:int;comment:source table sql waits" json:"sqlWaits"`
	SqlRuns     uint64  `gorm:"type:int;comment:source table sql runs" json:"sqlRuns"`
	SqlStops    uint64  `gorm:"type:int;comment:source table sql stops" json:"sqlStops"`
	Duration    float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	InitFlag    string  `gorm:"type:char(1);default:N;comment:the task sql init flag" json:"initFlag"`
	MigrateFlag string  `gorm:"type:char(1);default:N;comment:the task sql migrate finished flag" json:"migrateFlag"`
	*common.Entity
}

type SqlMigrateTask 

type SqlMigrateTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `gorm:"type:varchar(30);not null;uniqueIndex:uniq_schema_table_name_complex;" json:"taskName"`
	SchemaNameT     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:target schema name" json:"schemaNameT"`
	TableNameT      string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:target table name" json:"tableNameT"`
	SnapshotPointS  string  `gorm:"type:varchar(120);comment:source snapshot point" json:"snapshotPointS"`
	ColumnDetailO   string  `gorm:"type:longtext;comment:source column store origin information" json:"columnDetailO"`
	ColumnDetailS   string  `gorm:"type:longtext;comment:source column information" json:"columnDetailS"`
	ColumnDetailT   string  `gorm:"type:longtext;comment:source column information" json:"columnDetailT"`
	SqlHintT        string  `gorm:"type:varchar(300);comment:target sql hint" json:"sqlHintT"`
	ConsistentReadS string  `gorm:"type:varchar(10);comment:source sql consistent read" json:"consistentReadS"`
	SqlQueryS       string  `gorm:"type:varchar(600);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source sql query" json:"sqlQueryS"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	ErrorDetail     string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type StructCompareSummary 

type StructCompareSummary struct {
	ID             uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName       string  `` /* 129-byte string literal not displayed */
	SchemaNameS    string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableTotals    uint64  `gorm:"type:int;comment:source table table totals" json:"tableTotals"`
	TableEquals    uint64  `gorm:"type:int;comment:source table table equals" json:"TableEquals"`
	TableNotEquals uint64  `gorm:"type:int;comment:source table table not equals" json:"TableNotEquals"`
	TableFails     uint64  `gorm:"type:int;comment:source table table fails" json:"tableFails"`
	TableWaits     uint64  `gorm:"type:int;comment:source table table waits" json:"tableWaits"`
	TableRuns      uint64  `gorm:"type:int;comment:source table table runs" json:"tableRuns"`
	TableStops     uint64  `gorm:"type:int;comment:source table table stops" json:"tableStops"`
	InitFlag       string  `gorm:"type:char(1);default:N;comment:the task table init flag" json:"initFlag"`
	CompareFlag    string  `gorm:"type:char(1);default:N;comment:the task table compare finished flag" json:"compareFlag"`
	Duration       float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type StructCompareTask 

type StructCompareTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `gorm:"type:varchar(30);not null;uniqueIndex:uniq_schema_table_name;index:idx_task_name;comment:task name" json:"taskName"`
	SchemaNameS     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name;comment:source schema name" json:"schemaNameS"`
	TableNameS      string  `gorm:"type:varchar(60);uniqueIndex:uniq_schema_table_name;comment:source table name" json:"tableNameS"`
	TableTypeS      string  `gorm:"type:varchar(60);comment:source table type" json:"tableTypeS"`
	SchemaNameT     string  `gorm:"type:varchar(60);comment:target schema name" json:"schemaNameT"`
	TableNameT      string  `gorm:"type:varchar(60);comment:target table name" json:"tableNameT"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	SourceSqlDigest string  `gorm:"type:longtext;comment:origin sql digest" json:"sourceSqlDigest"`
	TargetSqlDigest string  `gorm:"type:longtext;comment:target sql digest" json:"targetSqlDigest"`
	CompareDetail   string  `gorm:"type:longtext;comment:compare detail" json:"compareDetail"`
	ErrorDetail     string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type StructGroupStatusResult 

type StructGroupStatusResult struct {
	TaskName     string `json:"taskName"`
	TaskStatus   string `json:"taskStatus"`
	StatusCounts int64  `json:"statusCounts"`
}

type StructMigrateSummary 

type StructMigrateSummary struct {
	ID           uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName     string  `` /* 129-byte string literal not displayed */
	SchemaNameS  string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name_complex;comment:source schema name" json:"schemaNameS"`
	TableTotals  uint64  `gorm:"type:int;comment:source table table totals" json:"tableTotals"`
	TableSuccess uint64  `gorm:"type:int;comment:source table table success" json:"tableSuccess"`
	TableFails   uint64  `gorm:"type:int;comment:source table table fails" json:"tableFails"`
	TableWaits   uint64  `gorm:"type:int;comment:source table table waits" json:"tableWaits"`
	TableRuns    uint64  `gorm:"type:int;comment:source table table runs" json:"tableRuns"`
	TableStops   uint64  `gorm:"type:int;comment:source table table stops" json:"tableStops"`
	InitFlag     string  `gorm:"type:char(1);default:N;comment:the task table init flag" json:"initFlag"`
	MigrateFlag  string  `gorm:"type:char(1);default:N;comment:the task table migrate finished flag" json:"migrateFlag"`
	Duration     float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type StructMigrateTask 

type StructMigrateTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `gorm:"type:varchar(30);not null;uniqueIndex:uniq_schema_table_name;index:idx_task_name;comment:task name" json:"taskName"`
	SchemaNameS     string  `gorm:"type:varchar(60);not null;uniqueIndex:uniq_schema_table_name;comment:source schema name" json:"schemaNameS"`
	TableNameS      string  `gorm:"type:varchar(60);uniqueIndex:uniq_schema_table_name;comment:source table name" json:"tableNameS"`
	TableTypeS      string  `gorm:"type:varchar(60);comment:source table type" json:"tableTypeS"`
	SchemaNameT     string  `gorm:"type:varchar(60);comment:target schema name" json:"schemaNameT"`
	TableNameT      string  `gorm:"type:varchar(60);comment:target table name" json:"tableNameT"`
	TaskStatus      string  `gorm:"type:varchar(50);not null;comment:task run status" json:"taskStatus"`
	SourceSqlDigest string  `gorm:"type:longtext;comment:origin sql digest" json:"sourceSqlDigest"`
	IncompSqlDigest string  `gorm:"type:longtext;comment:incompatible sql digest" json:"incompSqlDigest"`
	TargetSqlDigest string  `gorm:"type:longtext;comment:target sql digest" json:"targetSqlDigest"`
	TableAttrOption string  `gorm:"type:varchar(300);comment:source column datatype" json:"tableAttrOption"`
	ErrorDetail     string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration        float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type Task 

type Task struct {
	ID              uint64     `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string     `gorm:"type:varchar(30);not null;uniqueIndex:uniq_task_name;comment:task name" json:"taskName"`
	TaskMode        string     `gorm:"type:varchar(100);not null;comment:task mode" json:"taskMode"`
	TaskFlow        string     `gorm:"type:varchar(100);not null;comment:task flow" json:"taskFlow"`
	DatasourceNameS string     `gorm:"type:varchar(300);not null;comment:source datasource of task" json:"datasourceNameS"`
	DatasourceNameT string     `gorm:"type:varchar(300);not null;comment:target datasource of task" json:"datasourceNameT"`
	WorkerAddr      string     `gorm:"type:varchar(30);comment:worker addr" json:"workerAddr"`
	CaseFieldRuleS  string     `gorm:"type:varchar(30);comment:source case field rule" json:"caseFieldRuleS"`
	CaseFieldRuleT  string     `gorm:"type:varchar(30);comment:target case field rule" json:"CaseFieldRuleT"`
	TaskStatus      string     `gorm:"type:varchar(30);comment:task status" json:"taskStatus"`
	StartTime       *time.Time `gorm:"default:null;comment:task start running time" json:"startTime"`
	EndTime         *time.Time `gorm:"default:null;comment:task end running time" json:"endTime"`
	*common.Entity
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.