model

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.

Index

• Variables
• func CreateDatabaseConnection(cfg *Database, addRole, logLevel string) error
• func CreateDatabaseReadWrite(cfg *Database) error
• func CreateDatabaseSchema(cfg *Database) error
• func GetBuildInCompatibleRuleRW() buildin.IBuildInCompatibleRule
• func GetBuildInDefaultValueRuleRW() buildin.IBuildInDefaultValueRule
• func GetBuildInRuleRecordRW() buildin.IBuildInRuleRecord
• func GetIAssessMigrateTaskRW() task.IAssessMigrateTask
• func GetIBuildInDatatypeRuleRW() buildin.IBuildInDatatypeRule
• func GetIDataCompareResultRW() task.IDataCompareResult
• func GetIDataCompareRuleRW() rule.IDataCompareRule
• func GetIDataCompareSummaryRW() task.IDataCompareSummary
• func GetIDataCompareTaskRW() task.IDataCompareTask
• func GetIDataMigrateRuleRW() rule.IDataMigrateRule
• func GetIDataMigrateSummaryRW() task.IDataMigrateSummary
• func GetIDataMigrateTaskRW() task.IDataMigrateTask
• func GetIDataScanRuleRW() rule.IDataScanRule
• func GetIDataScanSummaryRW() task.IDataScanSummary
• func GetIDataScanTaskRW() task.IDataScanTask
• func GetIDatasourceRW() datasource.IDatasource
• func GetIMigrateColumnRouteRW() rule.IColumnRouteRule
• func GetIMigrateSchemaRouteRW() rule.ISchemaRouteRule
• func GetIMigrateTableRouteRW() rule.ITableRouteRule
• func GetIMigrateTaskSequenceRW() rule.IMigrateTaskSequence
• func GetIMigrateTaskTableRW() rule.IMigrateTaskTable
• func GetIMsgDdlRewriteRW() consume.IMsgDdlRewrite
• func GetIMsgTopicPartitionRW() consume.IMsgTopicPartition
• func GetIParamsRW() params.IParams
• func GetISchemaMigrateTaskRW() task.ISchemaMigrateTask
• func GetISequenceMigrateSummaryRW() task.ISequenceMigrateSummary
• func GetISequenceMigrateTaskRW() task.ISequenceMigrateTask
• func GetISqlMigrateRuleRW() rule.ISqlMigrateRule
• func GetISqlMigrateSummaryRW() task.ISqlMigrateSummary
• func GetISqlMigrateTaskRW() task.ISqlMigrateTask
• func GetIStructCompareSummaryRW() task.IStructCompareSummary
• func GetIStructCompareTaskRW() task.IStructCompareTask
• func GetIStructMigrateColumnRuleRW() migrate.IStructMigrateColumnRule
• func GetIStructMigrateSchemaRuleRW() migrate.IStructMigrateSchemaRule
• func GetIStructMigrateSummaryRW() task.IStructMigrateSummary
• func GetIStructMigrateTableAttrsRuleRW() migrate.IStructMigrateTableAttrsRule
• func GetIStructMigrateTableRuleRW() migrate.IStructMigrateTableRule
• func GetIStructMigrateTaskRW() task.IStructMigrateTask
• func GetIStructMigrateTaskRuleRW() migrate.IStructMigrateTaskRule
• func GetITaskLogRW() task.ILog
• func GetITaskRW() task.ITask
• func Transaction(ctx context.Context, fc func(txnCtx context.Context) error) (err error)
• type Database
  • func (d *Database) String() string

Variables

var DefaultDB *database

Functions

func CreateDatabaseConnection

func CreateDatabaseConnection(cfg *Database, addRole, logLevel string) error

CreateDatabaseConnection create database connection

func CreateDatabaseReadWrite

func CreateDatabaseReadWrite(cfg *Database) error

func CreateDatabaseSchema

func CreateDatabaseSchema(cfg *Database) error

func GetBuildInCompatibleRuleRW

func GetBuildInCompatibleRuleRW() buildin.IBuildInCompatibleRule

func GetBuildInDefaultValueRuleRW

func GetBuildInDefaultValueRuleRW() buildin.IBuildInDefaultValueRule

func GetBuildInRuleRecordRW

func GetBuildInRuleRecordRW() buildin.IBuildInRuleRecord

func GetIAssessMigrateTaskRW

func GetIAssessMigrateTaskRW() task.IAssessMigrateTask

func GetIBuildInDatatypeRuleRW

func GetIBuildInDatatypeRuleRW() buildin.IBuildInDatatypeRule

func GetIDataCompareResultRW

func GetIDataCompareResultRW() task.IDataCompareResult

func GetIDataCompareRuleRW

func GetIDataCompareRuleRW() rule.IDataCompareRule

func GetIDataCompareSummaryRW

func GetIDataCompareSummaryRW() task.IDataCompareSummary

func GetIDataCompareTaskRW

func GetIDataCompareTaskRW() task.IDataCompareTask

func GetIDataMigrateRuleRW

func GetIDataMigrateRuleRW() rule.IDataMigrateRule

func GetIDataMigrateSummaryRW

func GetIDataMigrateSummaryRW() task.IDataMigrateSummary

func GetIDataMigrateTaskRW

func GetIDataMigrateTaskRW() task.IDataMigrateTask

func GetIDataScanRuleRW

func GetIDataScanRuleRW() rule.IDataScanRule

func GetIDataScanSummaryRW

func GetIDataScanSummaryRW() task.IDataScanSummary

func GetIDataScanTaskRW

func GetIDataScanTaskRW() task.IDataScanTask

func GetIDatasourceRW

func GetIDatasourceRW() datasource.IDatasource

func GetIMigrateColumnRouteRW

func GetIMigrateColumnRouteRW() rule.IColumnRouteRule

func GetIMigrateSchemaRouteRW

func GetIMigrateSchemaRouteRW() rule.ISchemaRouteRule

func GetIMigrateTableRouteRW

func GetIMigrateTableRouteRW() rule.ITableRouteRule

func GetIMigrateTaskSequenceRW

func GetIMigrateTaskSequenceRW() rule.IMigrateTaskSequence

func GetIMigrateTaskTableRW

func GetIMigrateTaskTableRW() rule.IMigrateTaskTable

func GetIMsgDdlRewriteRW

func GetIMsgDdlRewriteRW() consume.IMsgDdlRewrite

func GetIMsgTopicPartitionRW

func GetIMsgTopicPartitionRW() consume.IMsgTopicPartition

func GetIParamsRW

func GetIParamsRW() params.IParams

func GetISchemaMigrateTaskRW

func GetISchemaMigrateTaskRW() task.ISchemaMigrateTask

func GetISequenceMigrateSummaryRW

func GetISequenceMigrateSummaryRW() task.ISequenceMigrateSummary

func GetISequenceMigrateTaskRW

func GetISequenceMigrateTaskRW() task.ISequenceMigrateTask

func GetISqlMigrateRuleRW

func GetISqlMigrateRuleRW() rule.ISqlMigrateRule

func GetISqlMigrateSummaryRW

func GetISqlMigrateSummaryRW() task.ISqlMigrateSummary

func GetISqlMigrateTaskRW

func GetISqlMigrateTaskRW() task.ISqlMigrateTask

func GetIStructCompareSummaryRW

func GetIStructCompareSummaryRW() task.IStructCompareSummary

func GetIStructCompareTaskRW

func GetIStructCompareTaskRW() task.IStructCompareTask

func GetIStructMigrateColumnRuleRW

func GetIStructMigrateColumnRuleRW() migrate.IStructMigrateColumnRule

func GetIStructMigrateSchemaRuleRW

func GetIStructMigrateSchemaRuleRW() migrate.IStructMigrateSchemaRule

func GetIStructMigrateSummaryRW

func GetIStructMigrateSummaryRW() task.IStructMigrateSummary

func GetIStructMigrateTableAttrsRuleRW

func GetIStructMigrateTableAttrsRuleRW() migrate.IStructMigrateTableAttrsRule

func GetIStructMigrateTableRuleRW

func GetIStructMigrateTableRuleRW() migrate.IStructMigrateTableRule

func GetIStructMigrateTaskRW

func GetIStructMigrateTaskRW() task.IStructMigrateTask

func GetIStructMigrateTaskRuleRW

func GetIStructMigrateTaskRuleRW() migrate.IStructMigrateTaskRule

func GetITaskLogRW

func GetITaskLogRW() task.ILog

func GetITaskRW

func GetITaskRW() task.ITask

func Transaction

func Transaction(ctx context.Context, fc func(txnCtx context.Context) error) (err error)

Transaction @Description: Transaction for service @Parameter ctx @Parameter fc @return error

Types

type Database

type Database struct {
	Host          string `toml:"host" json:"host"`
	Port          uint64 `toml:"port" json:"port"`
	Username      string `toml:"username" json:"username"`
	Password      string `toml:"password" json:"password"`
	Schema        string `toml:"schema" json:"schema"`
	SlowThreshold uint64 `toml:"slowThreshold" json:"slowThreshold"`
	InitThread    uint64 `toml:"initThread" json:"initThread"`
}

Database is database configuration.

func (*Database) String

func (d *Database) String() string