task

package

Go to main page

Versions in this module

v1

v1.0.22

May 27, 2025

v1.0.21

May 22, 2025

v1.0.20

May 14, 2025

v0

v0.0.19

Feb 13, 2025

Changes in this version

type DataCompareTask

+ ColumnDetailSS string

+ ColumnDetailTS string

type IDataCompareResult

+ DistinctDataCompareResultChunkByTaskStatus func(ctx context.Context, task *DataCompareResult) ([]string, error)

+ QueryDataCompareResultChunk func(ctx context.Context, task *DataCompareResult, chunkIds []string) ([]*DataCompareResult, error)

type IDataCompareTask

+ DistinctDataCompareTaskChunkByTaskStatus func(ctx context.Context, task *DataCompareTask) ([]string, error)

+ QueryDataCompareTaskChunk func(ctx context.Context, task *DataCompareTask, chunkIds []string) ([]*DataCompareTask, error)

type RWDataCompareResult

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

+ func (rw *RWDataCompareResult) QueryDataCompareResultChunk(ctx context.Context, task *DataCompareResult, chunkIds []string) ([]*DataCompareResult, error)

type RWDataCompareTask

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

+ func (rw *RWDataCompareTask) QueryDataCompareTaskChunk(ctx context.Context, task *DataCompareTask, chunkIds []string) ([]*DataCompareTask, error)

v0.0.18

Dec 18, 2024

v0.0.17

Dec 16, 2024

v0.0.16

Nov 12, 2024

v0.0.15

Oct 25, 2024

v0.0.14

Sep 23, 2024

Changes in this version

type IDataCompareResult

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

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

type RWDataCompareResult

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

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

v0.0.13

Sep 6, 2024

Changes in this version

+ type ISequenceMigrateSummary interface

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

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

+ DeleteSequenceMigrateSummaryName func(ctx context.Context, taskName []string) error

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

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

+ UpdateSequenceMigrateSummary func(ctx context.Context, task *SequenceMigrateSummary, ...) (*SequenceMigrateSummary, error)

+ type RWSequenceMigrateSummary struct

+ func NewSequenceMigrateSummaryRW(db *gorm.DB) *RWSequenceMigrateSummary

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

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

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

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

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

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

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

+ type SequenceMigrateSummary struct

+ Duration float64

+ ID uint64

+ InitFlag string

+ MigrateFlag string

+ SchemaNameS string

+ SeqFails uint64

+ SeqRuns uint64

+ SeqStops uint64

+ SeqSuccess uint64

+ SeqTotals uint64

+ SeqWaits uint64

+ TaskName string

v0.0.12

Aug 26, 2024

v0.0.11

Aug 24, 2024

Changes in this version

type IDataCompareSummary

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

type IDataMigrateSummary

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

type IDataScanSummary

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

type RWDataCompareSummary

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

type RWDataMigrateSummary

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

type RWDataScanSummary

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

v0.0.10

Aug 23, 2024

Changes in this version

type IDataCompareResult

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

+ type ISchemaMigrateTask interface

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

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

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

+ DeleteSchemaMigrateTask func(ctx context.Context, id uint64) error

+ DeleteSchemaMigrateTaskName func(ctx context.Context, taskName []string) error

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

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

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

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

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

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

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

+ type ISequenceMigrateTask interface

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

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

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

+ DeleteSequenceMigrateTask func(ctx context.Context, id uint64) error

+ DeleteSequenceMigrateTaskName func(ctx context.Context, taskName []string) error

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

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

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

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

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

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

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

type RWDataCompareResult

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

+ type RWSchemaMigrateTask struct

+ func NewSchemaMigrateTaskRW(db *gorm.DB) *RWSchemaMigrateTask

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type RWSequenceMigrateTask struct

+ func NewSequenceMigrateTaskRW(db *gorm.DB) *RWSequenceMigrateTask

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type SchemaMigrateTask struct

+ Duration float64

+ ID uint64

+ SchemaNameS string

+ SchemaNameT string

+ TargetSqlDigest string

+ TaskName string

+ TaskStatus string

+ type SequenceMigrateTask struct

+ Duration float64

+ ErrorDetail string

+ ID uint64

+ IsCompatible string

+ SchemaNameS string

+ SchemaNameT string

+ SequenceNameS string

+ SourceSqlDigest string

+ TargetSqlDigest string

+ TaskName string

+ TaskStatus string

v0.0.9

Aug 22, 2024

Changes in this version

type AssessMigrateTask

+ AssessFlag string

+ InitFlag string

type DataCompareSummary

+ CompareFlag string

+ InitFlag string

type DataMigrateSummary

+ InitFlag string

+ MigrateFlag string

type DataScanSummary

+ InitFlag string

+ ScanFlag string

type IDataMigrateTask

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

type RWDataMigrateTask

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

type SqlMigrateSummary

+ InitFlag string

+ MigrateFlag string

type StructCompareSummary

+ CompareFlag string

+ InitFlag string

type StructMigrateSummary

+ InitFlag string

+ MigrateFlag string

v0.0.8

Aug 8, 2024

Changes in this version

type DataCompareResult

+ ChunkID string

type DataCompareTask

+ ChunkDetailArgS string

+ ChunkDetailArgT string

+ ChunkID string

type DataMigrateTask

+ ChunkDetailArgS string

+ ChunkID string

type DataScanTask

+ ChunkDetailArgS string

+ ChunkID string

v0.0.7

Jul 24, 2024

Changes in this version

type IDataCompareTask

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

type IDataMigrateTask

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

type IDataScanTask

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

type RWDataCompareTask

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

type RWDataMigrateTask

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

type RWDataScanTask

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

v0.0.6

Jul 8, 2024

Changes in this version

+ type DataCompareResult struct

+ ChunkDetailS string

+ FixDetailT string

+ FixStmtType string

+ ID uint64

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ TaskName string

+ type IDataCompareResult interface

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

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

+ DeleteDataCompareResultName func(ctx context.Context, taskName []string) error

+ FindDataCompareResult func(ctx context.Context, task *DataCompareResult) ([]*DataCompareResult, error)

+ type RWDataCompareResult struct

+ func NewDataCompareResultRW(db *gorm.DB) *RWDataCompareResult

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

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

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

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

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

v0.0.5

Jun 26, 2024

v0.0.4

Jun 25, 2024

Changes in this version

type DataCompareSummary

+ SnapshotPointS string

+ SnapshotPointT string

type DataCompareTask

+ SnapshotPointS string

+ SnapshotPointT string

type DataMigrateSummary

+ SnapshotPointS string

type DataMigrateTask

+ SnapshotPointS string

type DataScanSummary

+ SnapshotPointS string

type DataScanTask

+ SnapshotPointS string

type SqlMigrateTask

+ SnapshotPointS string

v0.0.3

Jun 21, 2024

Changes in this version

type Task

+ TaskInit string

v0.0.2

Jun 18, 2024

v0.0.1

Jun 15, 2024

v0.0.0

Jun 8, 2024

Changes in this version

+ type AssessMigrateTask struct

+ AssessDetail string

+ AssessFile string

+ AssessUser string

+ Duration float64

+ ErrorDetail string

+ ID uint64

+ SchemaNameS string

+ TaskName string

+ TaskStatus string

+ type DataCompareSummary struct

+ ChunkEquals uint64

+ ChunkFails uint64

+ ChunkNotEquals uint64

+ ChunkRuns uint64

+ ChunkStops uint64

+ ChunkTotals uint64

+ ChunkWaits uint64

+ Duration float64

+ GlobalScnS uint64

+ ID uint64

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ TableRowsS uint64

+ TableSizeS float64

+ TaskName string

+ type DataCompareTask struct

+ ChunkDetailS string

+ ChunkDetailT string

+ ColumnDetailS string

+ ColumnDetailSO string

+ ColumnDetailT string

+ ColumnDetailTO string

+ CompareMethod string

+ ConsistentReadS string

+ Duration float64

+ ErrorDetail string

+ FixDetailAddT string

+ FixDetailDelT string

+ GlobalScnS uint64

+ ID uint64

+ SchemaNameS string

+ SchemaNameT string

+ SqlHintS string

+ SqlHintT string

+ TableNameS string

+ TableNameT string

+ TableTypeS string

+ TaskName string

+ TaskStatus string

+ type DataGroupChunkResult struct

+ ChunkTotals int64

+ SchemaNameS string

+ TableNameS string

+ TaskName string

+ type DataGroupStatusResult struct

+ StatusCounts int64

+ TaskName string

+ TaskStatus string

+ type DataGroupTaskStatusResult struct

+ SchemaNameS string

+ StatusTotals int64

+ TableNameS string

+ TaskName string

+ TaskStatus string

+ type DataMigrateSummary struct

+ ChunkFails uint64

+ ChunkRuns uint64

+ ChunkStops uint64

+ ChunkSuccess uint64

+ ChunkTotals uint64

+ ChunkWaits uint64

+ Duration float64

+ GlobalScnS uint64

+ ID uint64

+ Refused string

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ TableRowsS uint64

+ TableSizeS float64

+ TaskName string

+ type DataMigrateTask struct

+ ChunkDetailS string

+ ColumnDetailO string

+ ColumnDetailS string

+ ColumnDetailT string

+ ConsistentReadS string

+ CsvFile string

+ Duration float64

+ ErrorDetail string

+ GlobalScnS uint64

+ ID uint64

+ SchemaNameS string

+ SchemaNameT string

+ SqlHintS string

+ SqlHintT string

+ TableNameS string

+ TableNameT string

+ TableTypeS string

+ TaskName string

+ TaskStatus string

+ type DataScanSummary struct

+ ChunkFails uint64

+ ChunkRuns uint64

+ ChunkStops uint64

+ ChunkSuccess uint64

+ ChunkTotals uint64

+ ChunkWaits uint64

+ Duration float64

+ GlobalScnS uint64

+ ID uint64

+ SchemaNameS string

+ TableNameS string

+ TableRowsS uint64

+ TableSizeS float64

+ TaskName string

+ type DataScanTask struct

+ ChunkDetailS string

+ ColumnDetailS string

+ ConsistentReadS string

+ Duration float64

+ ErrorDetail string

+ GlobalScnS uint64

+ GroupColumnS string

+ ID uint64

+ Samplerate string

+ ScanResult string

+ SchemaNameS string

+ SqlHintS string

+ TableNameS string

+ TableTypeS string

+ TaskName string

+ TaskStatus string

+ type IAssessMigrateTask interface

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

+ DeleteAssessMigrateTask func(ctx context.Context, id uint64) error

+ DeleteAssessMigrateTaskName func(ctx context.Context, taskName []string) error

+ GetAssessMigrateTask func(ctx context.Context, task *AssessMigrateTask) ([]*AssessMigrateTask, error)

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

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

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

+ type IDataCompareSummary interface

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

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

+ DeleteDataCompareSummaryName func(ctx context.Context, taskName []string) error

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

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

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

+ type IDataCompareTask interface

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

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

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

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

+ DeleteDataCompareTaskName func(ctx context.Context, taskName []string) error

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

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

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

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

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

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

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

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

+ type IDataMigrateSummary interface

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

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

+ DeleteDataMigrateSummaryName func(ctx context.Context, taskName []string) error

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

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

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

+ type IDataMigrateTask interface

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

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

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

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

+ DeleteDataMigrateTaskName func(ctx context.Context, taskName []string) error

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

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

+ FindDataMigrateTaskGroupByTaskSchemaTable func(ctx context.Context, taskName string) ([]*DataGroupChunkResult, error)

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

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

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

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

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

+ type IDataScanSummary interface

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

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

+ DeleteDataScanSummaryName func(ctx context.Context, taskName []string) error

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

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

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

+ type IDataScanTask interface

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

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

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

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

+ DeleteDataScanTaskName func(ctx context.Context, taskName []string) error

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

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

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

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

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

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

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

+ type ILog interface

+ CreateLog func(ctx context.Context, l *Log) (*Log, error)

+ DeleteLog func(ctx context.Context, taskName []string) error

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

+ QueryLog func(ctx context.Context, l *Log) ([]*Log, error)

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

+ type ISqlMigrateSummary interface

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

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

+ DeleteSqlMigrateSummaryName func(ctx context.Context, taskName []string) error

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

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

+ type ISqlMigrateTask interface

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

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

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

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

+ DeleteSqlMigrateTaskName func(ctx context.Context, taskName []string) error

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

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

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

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

+ type IStructCompareSummary interface

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

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

+ DeleteStructCompareSummaryName func(ctx context.Context, taskName []string) error

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

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

+ UpdateStructCompareSummary func(ctx context.Context, task *StructCompareSummary, ...) (*StructCompareSummary, error)

+ type IStructCompareTask interface

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

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

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

+ DeleteStructCompareTask func(ctx context.Context, id uint64) error

+ DeleteStructCompareTaskName func(ctx context.Context, taskName []string) error

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

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

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

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

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

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

+ type IStructMigrateSummary interface

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

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

+ DeleteStructMigrateSummaryName func(ctx context.Context, taskName []string) error

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

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

+ UpdateStructMigrateSummary func(ctx context.Context, task *StructMigrateSummary, ...) (*StructMigrateSummary, error)

+ type IStructMigrateTask interface

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

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

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

+ DeleteStructMigrateTask func(ctx context.Context, id uint64) error

+ DeleteStructMigrateTaskName func(ctx context.Context, taskName []string) error

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

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

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

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

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

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

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

+ type ITask interface

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

+ DeleteTask func(ctx context.Context, taskName []string) error

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

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

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

+ type Log struct

+ ID uint64

+ LogDetail string

+ SchemaNameS string

+ TableNameS string

+ TaskName string

+ type RWAssessMigrateTask struct

+ func NewAssessMigrateTaskRW(db *gorm.DB) *RWAssessMigrateTask

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

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

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

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

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

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

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

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

+ type RWDataCompareSummary struct

+ func NewDataCompareSummaryRW(db *gorm.DB) *RWDataCompareSummary

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

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

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

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

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

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

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

+ type RWDataCompareTask struct

+ func NewDataCompareTaskRW(db *gorm.DB) *RWDataCompareTask

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type RWDataMigrateSummary struct

+ func NewDataMigrateSummaryRW(db *gorm.DB) *RWDataMigrateSummary

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

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

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

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

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

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

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

+ type RWDataMigrateTask struct

+ func NewDataMigrateTaskRW(db *gorm.DB) *RWDataMigrateTask

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type RWDataScanSummary struct

+ func NewDataScanSummaryRW(db *gorm.DB) *RWDataScanSummary

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

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

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

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

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

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

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

+ type RWDataScanTask struct

+ func NewDataScanTaskRW(db *gorm.DB) *RWDataScanTask

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type RWLog struct

+ func NewLogRW(db *gorm.DB) *RWLog

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

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

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

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

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

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

+ type RWSqlMigrateSummary struct

+ func NewSqlMigrateSummaryRW(db *gorm.DB) *RWSqlMigrateSummary

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

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

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

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

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

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

+ type RWSqlMigrateTask struct

+ func NewSqlMigrateTaskRW(db *gorm.DB) *RWSqlMigrateTask

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

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

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

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

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

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

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

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

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

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

+ type RWStructCompareSummary struct

+ func NewStructCompareSummaryRW(db *gorm.DB) *RWStructCompareSummary

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

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

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

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

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

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

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

+ type RWStructCompareTask struct

+ func NewStructCompareTaskRW(db *gorm.DB) *RWStructCompareTask

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

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

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

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

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

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

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

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

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

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

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

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

+ type RWStructMigrateSummary struct

+ func NewStructMigrateSummaryRW(db *gorm.DB) *RWStructMigrateSummary

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

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

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

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

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

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

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

+ type RWStructMigrateTask struct

+ func NewStructMigrateTaskRW(db *gorm.DB) *RWStructMigrateTask

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type RWTask struct

+ func NewTaskRW(db *gorm.DB) *RWTask

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

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

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

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

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

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

+ type SqlMigrateSummary struct

+ Duration float64

+ ID uint64

+ SqlFails uint64

+ SqlRuns uint64

+ SqlStops uint64

+ SqlSuccess uint64

+ SqlTotals uint64

+ SqlWaits uint64

+ TaskName string

+ type SqlMigrateTask struct

+ ColumnDetailO string

+ ColumnDetailS string

+ ColumnDetailT string

+ ConsistentReadS string

+ Duration float64

+ ErrorDetail string

+ GlobalScnS uint64

+ ID uint64

+ SchemaNameT string

+ SqlHintT string

+ SqlQueryS string

+ TableNameT string

+ TaskName string

+ TaskStatus string

+ type StructCompareSummary struct

+ Duration float64

+ ID uint64

+ SchemaNameS string

+ TableEquals uint64

+ TableFails uint64

+ TableNotEquals uint64

+ TableRuns uint64

+ TableStops uint64

+ TableTotals uint64

+ TableWaits uint64

+ TaskName string

+ type StructCompareTask struct

+ CompareDetail string

+ Duration float64

+ ErrorDetail string

+ ID uint64

+ SchemaNameS string

+ SchemaNameT string

+ SourceSqlDigest string

+ TableNameS string

+ TableNameT string

+ TableTypeS string

+ TargetSqlDigest string

+ TaskName string

+ TaskStatus string

+ type StructGroupStatusResult struct

+ StatusCounts int64

+ TaskName string

+ TaskStatus string

+ type StructMigrateSummary struct

+ Duration float64

+ ID uint64

+ SchemaNameS string

+ TableFails uint64

+ TableRuns uint64

+ TableStops uint64

+ TableSuccess uint64

+ TableTotals uint64

+ TableWaits uint64

+ TaskName string

+ type StructMigrateTask struct

+ Category string

+ Duration float64

+ ErrorDetail string

+ ID uint64

+ IncompSqlDigest string

+ SchemaNameS string

+ SchemaNameT string

+ SourceSqlDigest string

+ TableAttrOption string

+ TableNameS string

+ TableNameT string

+ TableTypeS string

+ TargetSqlDigest string

+ TaskName string

+ TaskStatus string

+ type Task struct

+ CaseFieldRuleS string

+ CaseFieldRuleT string

+ DatasourceNameS string

+ DatasourceNameT string

+ EndTime *time.Time

+ ID uint64

+ StartTime *time.Time

+ TaskFlow string

+ TaskMode string

+ TaskName string

+ TaskStatus string

+ WorkerAddr string

v0.0.0-beta.3

Jun 7, 2024

v0.0.0-beta.2

Jun 7, 2024

v0.0.0-beta.1

Jun 7, 2024

v0.0.0-beta

May 23, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL