Method GetThrottleControlReplicaKeys

go/base/context.go:876–883

()

}

func (mctx *MigrationContext) GetThrottleControlReplicaKeys() *mysql.InstanceKeyMap {
	mctx.throttleMutex.Lock()
	defer mctx.throttleMutex.Unlock()

	keys := mysql.NewInstanceKeyMap()
	keys.AddKeys(mctx.throttleControlReplicaKeys.GetInstanceKeys())
	return keys
}

func (mctx *MigrationContext) ReadThrottleControlReplicaKeys(throttleControlReplicas string) error {
	keys := mysql.NewInstanceKeyMap()