task

package
v0.0.0-beta.1 Latest Latest
Warning

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

 Go to latest Published: Jun 7, 2024 License: Apache-2.0 Imports: 7 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(100);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"`
	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"`
	ErrorDetail  string  `gorm:"type:longtext;comment:error detail" json:"errorDetail"`
	Duration     float64 `gorm:"comment:run duration, size: seconds" json:"duration"`
	*common.Entity
}

type DataCompareSummary 

type DataCompareSummary struct {
	ID             uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName       string  `` /* 130-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"`
	GlobalScnS     uint64  `gorm:"type:bigint;comment:source global scn" json:"globalScnS"`
	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"`
	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  `` /* 130-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"`
	GlobalScnS      uint64  `gorm:"type:bigint;comment:source global scn" json:"globalScnS"`
	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"`
	ChunkDetailS    string  `` /* 130-byte string literal not displayed */
	ChunkDetailT    string  `gorm:"type:varchar(500);not null;comment:target table chunk detail" json:"chunkDetailT"`
	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"`
	FixDetailAddT   string  `gorm:"type:longtext;comment:fix detail infos used to query information" json:"fixDetailAddT"`
	FixDetailDelT   string  `gorm:"type:longtext;comment:fix detail infos used to query information" json:"fixDetailDelT"`
	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  `` /* 130-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"`
	GlobalScnS   uint64  `gorm:"type:bigint;comment:source global scn" json:"globalScnS"`
	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"`
	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  `` /* 130-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"`
	GlobalScnS      uint64  `gorm:"type:bigint;comment:source global scn" json:"globalScnS"`
	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"`
	ChunkDetailS    string  `` /* 130-byte string literal not displayed */
	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  `` /* 130-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"`
	GlobalScnS   uint64  `gorm:"type:bigint;comment:source global scn" json:"globalScnS"`
	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"`
	*common.Entity
}

type DataScanTask 

type DataScanTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `` /* 130-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"`
	GlobalScnS      uint64  `gorm:"type:bigint;comment:source global scn" json:"globalScnS"`
	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"`
	ChunkDetailS    string  `` /* 130-byte string literal not displayed */
	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 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
}

type IDataCompareTask 

type IDataCompareTask interface {
	CreateDataCompareTask(ctx context.Context, task *DataCompareTask) (*DataCompareTask, error)
	CreateInBatchDataCompareTask(ctx context.Context, task []*DataCompareTask, 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)
	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)
	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, 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)
	FindDataMigrateTaskBySchemaTableChunkStatus(ctx context.Context, task *DataMigrateTask) ([]*DataGroupTaskStatusResult, error)
	FindDataMigrateTaskGroupByTaskSchemaTable(ctx context.Context, taskName string) ([]*DataGroupChunkResult, 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)
	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, 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)
	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) ([]*Log, error)
	ListLog(ctx context.Context, page uint64, pageSize uint64) ([]*Log, error)
	DeleteLog(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, 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(100);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 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) 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, 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) 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) 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, 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) FindDataMigrateTaskGroupByTaskSchemaTable 

func (rw *RWDataMigrateTask) FindDataMigrateTaskGroupByTaskSchemaTable(ctx context.Context, taskName string) ([]*DataGroupChunkResult, 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) 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) 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) 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, 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) 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) ([]*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 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, 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 SqlMigrateSummary 

type SqlMigrateSummary struct {
	ID         uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName   string  `gorm:"type:varchar(100);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"`
	*common.Entity
}

type SqlMigrateTask 

type SqlMigrateTask struct {
	ID              uint64  `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName        string  `gorm:"type:varchar(100);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"`
	GlobalScnS      uint64  `gorm:"type:bigint;comment:source global scn" json:"globalScnS"`
	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(300);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  `` /* 130-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"`
	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(100);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  `` /* 130-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"`
	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(100);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"`
	Category        string  `gorm:"type:varchar(300);comment:create sql category" json:"category"`
	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(100);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.