Function NewMigrationContext

go/base/context.go:310–337

()

}

func NewMigrationContext() *MigrationContext {
	ctx, cancelFunc := context.WithCancel(context.Background())
	return &MigrationContext{
		Uuid:                                uuid.NewString(),
		defaultNumRetries:                   60,
		ChunkSize:                           1000,
		InspectorConnectionConfig:           mysql.NewConnectionConfig(),
		ApplierConnectionConfig:             mysql.NewConnectionConfig(),
		MaxLagMillisecondsThrottleThreshold: 1500,
		CutOverLockTimeoutSeconds:           3,
		DMLBatchSize:                        10,
		etaNanoseonds:                       ETAUnknown,
		maxLoad:                             NewLoadMap(),
		criticalLoad:                        NewLoadMap(),
		throttleMutex:                       &sync.Mutex{},
		throttleHTTPMutex:                   &sync.Mutex{},
		throttleControlReplicaKeys:          mysql.NewInstanceKeyMap(),
		configMutex:                         &sync.Mutex{},
		pointOfInterestTimeMutex:            &sync.Mutex{},
		lastHeartbeatOnChangelogMutex:       &sync.Mutex{},
		ColumnRenameMap:                     make(map[string]string),
		PanicAbort:                          make(chan error),
		ctx:                                 ctx,
		cancelFunc:                          cancelFunc,
		abortMutex:                          &sync.Mutex{},
		Log:                                 NewDefaultLogger(),
	}
}

func (mctx *MigrationContext) SetConnectionConfig(storageEngine string) error {
	var transactionIsolation string