meta

package

Go to main page

Versions in this module

v1

v1.0.33

Mar 25, 2024

v1.0.32

Mar 1, 2024

v1.0.31

Jan 23, 2024

v1.0.30

Jan 20, 2024

v1.0.29

Jan 12, 2024

v1.0.28

Dec 29, 2023

v1.0.27

Dec 13, 2023

v1.0.26

Nov 29, 2023

v1.0.25

Nov 27, 2023

v1.0.24

Nov 24, 2023

v1.0.23

Nov 22, 2023

v1.0.22

Sep 8, 2023

v1.0.21

Aug 16, 2023

v1.0.20

Jul 26, 2023

v1.0.19

Jul 26, 2023

v1.0.18

Jul 18, 2023

v1.0.17

Jul 15, 2023

Changes in this version

type FullSyncMeta

+ SQLHint string

v1.0.16

Jun 21, 2023

Changes in this version

type FullSyncMeta

+ ConsistentRead string

type WaitSyncMeta

+ ConsistentRead string

v1.0.15

Jun 1, 2023

v1.0.14

May 23, 2023

v1.0.13

May 9, 2023

Changes in this version

+ type ChunkErrorDetail struct

+ ChunkDetailS string

+ DBTypeS string

+ DBTypeT string

+ ErrorDetail string

+ ErrorSQL string

+ ID uint

+ InfoDetail string

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ TaskMode string

+ func NewChunkErrorDetailModel(m *Meta) *ChunkErrorDetail

+ func (rw *ChunkErrorDetail) CreateChunkErrorDetail(ctx context.Context, createS *ChunkErrorDetail) error

+ func (rw *ChunkErrorDetail) DeleteChunkErrorDetailBySchemaTaskMode(ctx context.Context, deleteS *ChunkErrorDetail) error

+ func (rw *ChunkErrorDetail) ParseSchemaTable() (string, error)

type ErrorLogDetail

+ SourceDDL string

+ TargetDDL string

type FullSyncMeta

+ func (rw *FullSyncMeta) DeleteFullSyncMetaBySchemaTableChunk(ctx context.Context, deleteS *FullSyncMeta) error

+ func (rw *FullSyncMeta) UpdateFullSyncMetaChunk(ctx context.Context, detailS *FullSyncMeta, updates map[string]interface{}) error

type Transaction

+ func (rw *Transaction) UpdateFullSyncMetaChunkAndCreateChunkErrorDetail(ctx context.Context, detailS *FullSyncMeta, updateS map[string]interface{}, ...) error

type WaitSyncMeta

+ TableNumRows uint64

v1.0.12

Mar 11, 2023

Changes in this version

+ func ArrayStructGroupsOf(fsm []T, num int64) [][]T

type BuildinDatatypeRule

+ func (rw *BuildinDatatypeRule) InitO2TBuildinDatatypeRule(ctx context.Context) error

+ func (rw *BuildinDatatypeRule) InitT2OBuildinDatatypeRule(ctx context.Context) error

type BuildinGlobalDefaultval

+ func (rw *BuildinGlobalDefaultval) InitMT2OBuildinGlobalDefaultValue(ctx context.Context) error

+ func (rw *BuildinGlobalDefaultval) InitO2MTBuildinGlobalDefaultValue(ctx context.Context) error

type BuildinObjectCompatible

+ func (rw *BuildinObjectCompatible) InitO2TBuildinObjectCompatible(ctx context.Context) error

v1.0.11

Mar 8, 2023

v1.0.10

Feb 19, 2023

Changes in this version

type DataCompareMeta

+ ColumnDetailS string

+ ColumnDetailT string

+ ErrorDetail string

+ InfoDetail string

+ TaskMode string

+ TaskStatus string

+ func (rw *DataCompareMeta) CountsDataCompareMetaByTaskTable(ctx context.Context, dataErr *DataCompareMeta) (int64, error)

+ func (rw *DataCompareMeta) CountsErrorDataCompareMeta(ctx context.Context, dataErr *DataCompareMeta) (int64, error)

+ func (rw *DataCompareMeta) DistinctDataCompareMetaTableNameSByTaskStatus(ctx context.Context, detailS *DataCompareMeta) ([]string, error)

+ func (rw *DataCompareMeta) UpdateDataCompareMeta(ctx context.Context, deleteS *DataCompareMeta, updates map[string]interface{}) error

type ErrorLogDetail

+ SchemaNameT string

+ TableNameT string

+ TaskMode string

+ TaskStatus string

type FullSyncMeta

+ ChunkDetailS string

+ ColumnDetailS string

+ ErrorDetail string

+ InfoDetail string

+ TaskMode string

+ TaskStatus string

+ func (rw *FullSyncMeta) CountsErrorFullSyncMeta(ctx context.Context, dataErr *FullSyncMeta) (int64, error)

+ func (rw *FullSyncMeta) CountsFullSyncMetaByTaskTable(ctx context.Context, dataErr *FullSyncMeta) (int64, error)

+ func (rw *FullSyncMeta) DistinctFullSyncMetaTableNameSByTaskStatus(ctx context.Context, detailS *FullSyncMeta) ([]string, error)

+ func (rw *FullSyncMeta) UpdateFullSyncMeta(ctx context.Context, deleteS *FullSyncMeta, updates map[string]interface{}) error

type Transaction

+ func (rw *Transaction) BatchCreateDataCompareMetaAndUpdateWaitSyncMeta(ctx context.Context, dataDiffMeta []DataCompareMeta, batchSize int, ...) error

+ func (rw *Transaction) BatchCreateFullSyncMetaAndUpdateWaitSyncMeta(ctx context.Context, dataDiffMeta []FullSyncMeta, batchSize int, ...) error

+ func (rw *Transaction) CreateErrorDetailAndUpdateWaitSyncMetaTaskStatus(ctx context.Context, errLogDetail *ErrorLogDetail, waitSyncMeta *WaitSyncMeta) error

+ func (rw *Transaction) DeleteTableDataCompareMetaAndUpdateWaitSyncMeta(ctx context.Context, deleteS *DataCompareMeta, updateS *WaitSyncMeta) error

+ func (rw *Transaction) DeleteTableFullSyncMetaAndUpdateWaitSyncMeta(ctx context.Context, deleteS *FullSyncMeta, updateS *WaitSyncMeta) error

type WaitSyncMeta

+ ChunkFailedNums int64

+ ChunkSuccessNums int64

+ ChunkTotalNums int64

+ GlobalScnS uint64

+ TaskMode string

+ TaskStatus string

+ func (rw *WaitSyncMeta) CountsErrWaitSyncMetaBySchema(ctx context.Context, dataErr *WaitSyncMeta) (int64, error)

+ func (rw *WaitSyncMeta) DeleteWaitSyncMetaSuccessTables(ctx context.Context, deleteS *WaitSyncMeta, tables []string) error

+ func (rw *WaitSyncMeta) DetailWaitSyncMetaSuccessTables(ctx context.Context, detailS *WaitSyncMeta) ([]string, error)

+ func (rw *WaitSyncMeta) QueryWaitSyncMetaByPartTask(ctx context.Context, queryS *WaitSyncMeta) ([]WaitSyncMeta, error)

v1.0.9

Jan 31, 2023

Changes in this version

type BuildinColumnDefaultval

+ ColumnNameS string

+ SchemaNameS string

+ TableNameS string

+ type BuildinGlobalDefaultval struct

+ DBTypeS string

+ DBTypeT string

+ DefaultValueS string

+ DefaultValueT string

+ ID uint

+ func NewBuildinGlobalDefaultvalModel(m *Meta) *BuildinGlobalDefaultval

+ func (rw *BuildinGlobalDefaultval) CreateGlobalDefaultVal(ctx context.Context, createS *BuildinGlobalDefaultval) error

+ func (rw *BuildinGlobalDefaultval) DetailGlobalDefaultVal(ctx context.Context, detailS *BuildinGlobalDefaultval) ([]BuildinGlobalDefaultval, error)

+ func (rw *BuildinGlobalDefaultval) InitM2OBuildinGlobalDefaultValue(ctx context.Context) error

+ func (rw *BuildinGlobalDefaultval) InitO2MBuildinGlobalDefaultValue(ctx context.Context) error

+ func (rw *BuildinGlobalDefaultval) ParseSchemaTable() (string, error)

+ func (rw *BuildinGlobalDefaultval) RowsAffected(ctx context.Context, defaultVal *BuildinGlobalDefaultval) int64

v1.0.8

Jan 2, 2023

Changes in this version

+ type BaseModel struct

+ Comment string

+ CreatedAt string

+ UpdatedAt string

+ func (v *BaseModel) BeforeCreate(db *gorm.DB) (err error)

+ func (v *BaseModel) BeforeUpdate(db *gorm.DB) (err error)

+ type BuildinColumnDefaultval struct

+ DBTypeS string

+ DBTypeT string

+ DefaultValueS string

+ DefaultValueT string

+ ID uint

+ func NewBuildinColumnDefaultvalModel(m *Meta) *BuildinColumnDefaultval

+ func (rw *BuildinColumnDefaultval) CreateColumnDefaultVal(ctx context.Context, createS *BuildinColumnDefaultval) error

+ func (rw *BuildinColumnDefaultval) DetailColumnDefaultVal(ctx context.Context, detailS *BuildinColumnDefaultval) ([]BuildinColumnDefaultval, error)

+ func (rw *BuildinColumnDefaultval) InitM2OBuildinColumnDefaultValue(ctx context.Context) error

+ func (rw *BuildinColumnDefaultval) InitO2MBuildinColumnDefaultValue(ctx context.Context) error

+ func (rw *BuildinColumnDefaultval) ParseSchemaTable() (string, error)

+ func (rw *BuildinColumnDefaultval) RowsAffected(ctx context.Context, defaultVal *BuildinColumnDefaultval) int64

+ type BuildinDatatypeRule struct

+ DBTypeS string

+ DBTypeT string

+ DatatypeNameS string

+ DatatypeNameT string

+ ID uint

+ func NewBuildinDatatypeRuleModel(m *Meta) *BuildinDatatypeRule

+ func (rw *BuildinDatatypeRule) BatchQueryBuildinDatatype(ctx context.Context, detailS *BuildinDatatypeRule) ([]BuildinDatatypeRule, error)

+ func (rw *BuildinDatatypeRule) InitM2OBuildinDatatypeRule(ctx context.Context) error

+ func (rw *BuildinDatatypeRule) InitO2MBuildinDatatypeRule(ctx context.Context) error

+ func (rw *BuildinDatatypeRule) ParseSchemaTable() (string, error)

+ type BuildinObjectCompatible struct

+ DBTypeS string

+ DBTypeT string

+ ID uint

+ IsCompatible string

+ IsConvertible string

+ ObjectNameS string

+ func NewBuildinObjectCompatibleModel(m *Meta) *BuildinObjectCompatible

+ func (rw *BuildinObjectCompatible) BatchQueryObjAssessCompatible(ctx context.Context, detailS *BuildinObjectCompatible) ([]BuildinObjectCompatible, error)

+ func (rw *BuildinObjectCompatible) InitO2MBuildinObjectCompatible(ctx context.Context) error

+ func (rw *BuildinObjectCompatible) ParseSchemaTable() (string, error)

+ type ColumnDatatypeRule struct

+ ColumnNameS string

+ ColumnTypeS string

+ ColumnTypeT string

+ DBTypeS string

+ DBTypeT string

+ ID uint

+ SchemaNameS string

+ TableNameS string

+ func NewColumnDatatypeRuleModel(m *Meta) *ColumnDatatypeRule

+ func (rw *ColumnDatatypeRule) CreateColumnRule(ctx context.Context, createS *ColumnDatatypeRule) error

+ func (rw *ColumnDatatypeRule) DetailColumnRule(ctx context.Context, detailS *ColumnDatatypeRule) ([]ColumnDatatypeRule, error)

+ func (rw *ColumnDatatypeRule) ParseSchemaTable() (string, error)

+ type DataCompareMeta struct

+ ColumnInfoS string

+ ColumnInfoT string

+ DBTypeS string

+ DBTypeT string

+ ID uint

+ IsPartition string

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ WhereColumn string

+ WhereRange string

+ func NewDataCompareMetaModel(m *Meta) *DataCompareMeta

+ func (rw *DataCompareMeta) BatchCreateDataCompareMeta(ctx context.Context, createS []DataCompareMeta, batchSize int) error

+ func (rw *DataCompareMeta) CreateDataCompareMeta(ctx context.Context, createS *DataCompareMeta) error

+ func (rw *DataCompareMeta) DeleteDataCompareMeta(ctx context.Context, deleteS *DataCompareMeta) error

+ func (rw *DataCompareMeta) DetailDataCompareMeta(ctx context.Context, detailS *DataCompareMeta) (interface{}, error)

+ func (rw *DataCompareMeta) DistinctDataCompareMetaTableNameS(ctx context.Context, detailS *DataCompareMeta) ([]string, error)

+ func (rw *DataCompareMeta) ParseSchemaTable() (string, error)

+ func (rw *DataCompareMeta) TruncateDataCompareMeta(ctx context.Context) error

+ type ErrorLogDetail struct

+ DBTypeS string

+ DBTypeT string

+ ErrorDetail string

+ ID uint

+ InfoDetail string

+ RunMode string

+ RunStatus string

+ SchemaNameS string

+ TableNameS string

+ func NewErrorLogDetailModel(m *Meta) *ErrorLogDetail

+ func (rw *ErrorLogDetail) CountsErrorLogBySchema(ctx context.Context, detailS *ErrorLogDetail) (int64, error)

+ func (rw *ErrorLogDetail) CountsErrorLogBySchemaTable(ctx context.Context, detailS *ErrorLogDetail) (int64, error)

+ func (rw *ErrorLogDetail) CreateErrorLog(ctx context.Context, createS *ErrorLogDetail) error

+ func (rw *ErrorLogDetail) DetailErrorLog(ctx context.Context, detailS *ErrorLogDetail) ([]ErrorLogDetail, error)

+ func (rw *ErrorLogDetail) ParseSchemaTable() (string, error)

+ type FullSyncMeta struct

+ CSVFile string

+ ColumnInfoS string

+ DBTypeS string

+ DBTypeT string

+ GlobalScnS uint64

+ ID uint

+ IsPartition string

+ Mode string

+ RowidInfoS string

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ func NewFullSyncMetaModel(m *Meta) *FullSyncMeta

+ func (rw *FullSyncMeta) BatchCreateFullSyncMeta(ctx context.Context, createS []FullSyncMeta, batchSize int) error

+ func (rw *FullSyncMeta) DeleteFullSyncMetaBySchemaSyncMode(ctx context.Context, deleteS *FullSyncMeta) error

+ func (rw *FullSyncMeta) DeleteFullSyncMetaBySchemaTableRowid(ctx context.Context, deleteS *FullSyncMeta) error

+ func (rw *FullSyncMeta) DetailFullSyncMeta(ctx context.Context, detailS *FullSyncMeta) ([]FullSyncMeta, error)

+ func (rw *FullSyncMeta) DistinctFullSyncMetaByTableNameS(ctx context.Context, detailS *FullSyncMeta) ([]string, error)

+ func (rw *FullSyncMeta) ParseSchemaTable() (string, error)

+ func (rw *FullSyncMeta) String() string

+ type IncrSyncMeta struct

+ DBTypeS string

+ DBTypeT string

+ GlobalScnS uint64

+ ID uint

+ IsPartition string

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ TableScnS uint64

+ func NewIncrSyncMetaModel(m *Meta) *IncrSyncMeta

+ func (rw *IncrSyncMeta) BatchCreateIncrSyncMeta(ctx context.Context, createS []IncrSyncMeta, batchSize int) error

+ func (rw *IncrSyncMeta) CountsIncrSyncMetaBySchemaTable(ctx context.Context, detailS *IncrSyncMeta) (int64, error)

+ func (rw *IncrSyncMeta) DetailIncrSyncMetaBySchema(ctx context.Context, detailS *IncrSyncMeta) ([]IncrSyncMeta, error)

+ func (rw *IncrSyncMeta) GetIncrSyncMetaMinGlobalScnSBySchema(ctx context.Context, detailS *IncrSyncMeta) (uint64, error)

+ func (rw *IncrSyncMeta) GetIncrSyncMetaMinTableScnSBySchema(ctx context.Context, detailS *IncrSyncMeta) (uint64, error)

+ func (rw *IncrSyncMeta) ParseSchemaTable() (string, error)

+ func (rw *IncrSyncMeta) UpdateIncrSyncMeta(ctx context.Context, detailS *IncrSyncMeta) error

+ type Meta struct

+ GormDB *gorm.DB

+ func NewMetaDBEngine(ctx context.Context, mysqlCfg config.MySQLConfig, slowThreshold int) (*Meta, error)

+ func WrapGormDB(gormDB *gorm.DB) *Meta

+ func (m *Meta) DB(ctx context.Context) *gorm.DB

+ func (m *Meta) InitDefaultValue(ctx context.Context) error

+ func (m *Meta) MigrateTables() (err error)

+ type SchemaDatatypeRule struct

+ ColumnTypeS string

+ ColumnTypeT string

+ DBTypeS string

+ DBTypeT string

+ ID uint

+ SchemaNameS string

+ func NewSchemaDatatypeRuleModel(m *Meta) *SchemaDatatypeRule

+ func (rw *SchemaDatatypeRule) DetailSchemaRule(ctx context.Context, detailS *SchemaDatatypeRule) ([]SchemaDatatypeRule, error)

+ func (rw *SchemaDatatypeRule) ParseSchemaTable() (string, error)

+ type TableDatatypeRule struct

+ ColumnTypeS string

+ ColumnTypeT string

+ DBTypeS string

+ DBTypeT string

+ ID uint

+ SchemaNameS string

+ TableNameS string

+ func NewTableDatatypeRuleModel(m *Meta) *TableDatatypeRule

+ func (rw *TableDatatypeRule) DetailTableRule(ctx context.Context, detailS *TableDatatypeRule) ([]TableDatatypeRule, error)

+ func (rw *TableDatatypeRule) ParseSchemaTable() (string, error)

+ type TableNameRule struct

+ DBTypeS string

+ DBTypeT string

+ ID uint

+ SchemaNameS string

+ SchemaNameT string

+ TableNameS string

+ TableNameT string

+ func NewTableNameRuleModel(m *Meta) *TableNameRule

+ func (rw *TableNameRule) DetailTableNameRule(ctx context.Context, detailS *TableNameRule) ([]TableNameRule, error)

+ func (rw *TableNameRule) ParseSchemaTable() (string, error)

+ type Transaction struct

+ func NewCommonModel(m *Meta) *Transaction

+ func (rw *Transaction) CreateDataCompareMetaAndUpdateWaitSyncMeta(ctx context.Context, dataDiffMeta *DataCompareMeta, waitSyncMeta *WaitSyncMeta) error

+ func (rw *Transaction) CreateFullSyncMetaAndUpdateWaitSyncMeta(ctx context.Context, fullSyncMeta *FullSyncMeta, waitSyncMeta *WaitSyncMeta) error

+ func (rw *Transaction) DeleteIncrSyncMetaAndWaitSyncMeta(ctx context.Context, incrSyncMeta *IncrSyncMeta, waitSyncMeta *WaitSyncMeta) error

+ func (rw *Transaction) UpdateIncrSyncMetaSCNByArchivedLog(ctx context.Context, dbTypeS, dbTypeT, sourceSchemaName string, ...) error

+ func (rw *Transaction) UpdateIncrSyncMetaSCNByCurrentRedo(ctx context.Context, dbTypeS, dbTypeT, sourceSchemaName string, ...) error

+ func (rw *Transaction) UpdateIncrSyncMetaSCNByNonCurrentRedo(ctx context.Context, dbTypeS, dbTypeT, sourceSchemaName string, ...) error

+ type WaitSyncMeta struct

+ DBTypeS string

+ DBTypeT string

+ FullGlobalSCN uint64

+ FullSplitTimes int

+ ID uint

+ IsPartition string

+ Mode string

+ SchemaNameS string

+ TableNameS string

+ func NewWaitSyncMetaModel(m *Meta) *WaitSyncMeta

+ func (rw *WaitSyncMeta) BatchQueryWaitSyncMeta(ctx context.Context, queryS *WaitSyncMeta) ([]WaitSyncMeta, error)

+ func (rw *WaitSyncMeta) CreateWaitSyncMeta(ctx context.Context, createS *WaitSyncMeta) error

+ func (rw *WaitSyncMeta) DeleteWaitSyncMeta(ctx context.Context, deleteS *WaitSyncMeta) error

+ func (rw *WaitSyncMeta) DetailWaitSyncMeta(ctx context.Context, detailS *WaitSyncMeta) ([]WaitSyncMeta, error)

+ func (rw *WaitSyncMeta) DetailWaitSyncMetaBySchema(ctx context.Context, detailS *WaitSyncMeta) ([]WaitSyncMeta, error)

+ func (rw *WaitSyncMeta) DetailWaitSyncMetaBySchemaTableSCN(ctx context.Context, detailS *WaitSyncMeta) ([]WaitSyncMeta, error)

+ func (rw *WaitSyncMeta) ModifyWaitSyncMetaColumnFullSplitTimesZero(ctx context.Context, detailS *WaitSyncMeta) error

+ func (rw *WaitSyncMeta) ParseSchemaTable() (string, error)

+ func (rw *WaitSyncMeta) UpdateWaitSyncMeta(ctx context.Context, detailS *WaitSyncMeta) error

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