[core] config source_core_dir and target_core_dir

Author: jackblack369

internal/configure/topology/dc_get.go

@@ -131,7 +131,8 @@ func (dc *DeployConfig) GetReportUsage() bool        { return dc.getBool(CONFIG_
 func (dc *DeployConfig) GetContainerImage() string   { return dc.getString(CONFIG_CONTAINER_IMAGE) }
 func (dc *DeployConfig) GetLogDir() string           { return dc.getString(CONFIG_LOG_DIR) }
 func (dc *DeployConfig) GetDataDir() string          { return dc.getString(CONFIG_DATA_DIR) }
-func (dc *DeployConfig) GetCoreDir() string          { return dc.getString(CONFIG_CORE_DIR) }
+func (dc *DeployConfig) GetSourceCoreDir() string    { return dc.getString(CONFIG_SOURCE_CORE_DIR) }
+func (dc *DeployConfig) GetTargetCoreDir() string    { return dc.getString(CONFIG_TARGET_CORE_DIR) }
 func (dc *DeployConfig) GetEnv() string              { return dc.getString(CONFIG_ENV) }
 func (dc *DeployConfig) GetListenIp() string         { return dc.getString(CONFIG_LISTEN_IP) }
 func (dc *DeployConfig) GetListenPort() int          { return dc.getInt(CONFIG_LISTEN_PORT) }

internal/configure/topology/dc_item.go

@@ -124,8 +124,15 @@ var (
 		nil,
 	)
 
-	CONFIG_CORE_DIR = itemset.insert(
-		"core_dir",
+	CONFIG_SOURCE_CORE_DIR = itemset.insert(
+		"source_core_dir",
+		REQUIRE_STRING,
+		true,
+		nil,
+	)
+
+	CONFIG_TARGET_CORE_DIR = itemset.insert(
+		"target_core_dir",
 		REQUIRE_STRING,
 		true,
 		nil,

internal/task/task/checker/common.go

@@ -174,16 +174,20 @@ func getServiceDirectorys(dc *topology.DeployConfig) []Directory {
 	dirs := []Directory{}
 	logDir := dc.GetLogDir()
 	dataDir := dc.GetDataDir()
-	coreDir := dc.GetCoreDir()
+	sourceCoreDir := dc.GetSourceCoreDir()
+	targetCoreDir := dc.GetTargetCoreDir()
 
 	if len(logDir) > 0 {
 		dirs = append(dirs, Directory{LOG_DIR, logDir})
 	}
 	if len(dataDir) > 0 {
 		dirs = append(dirs, Directory{DATA_DIR, dataDir})
 	}
-	if len(coreDir) > 0 {
-		dirs = append(dirs, Directory{CORE_DIR, coreDir})
+	if len(sourceCoreDir) > 0 {
+		dirs = append(dirs, Directory{CORE_DIR, sourceCoreDir})
+	}
+	if len(targetCoreDir) > 0 {
+		dirs = append(dirs, Directory{CORE_DIR, targetCoreDir})
 	}
 
 	return dirs

internal/task/task/common/create_container.go

@@ -168,7 +168,8 @@ func getMountVolumes(dc *topology.DeployConfig) []step.Volume {
 	layout := dc.GetProjectLayout()
 	logDir := dc.GetLogDir()
 	dataDir := dc.GetDataDir()
-	coreDir := dc.GetCoreDir()
+	sourceCoreDir := dc.GetSourceCoreDir()
+	targetCoreDir := dc.GetTargetCoreDir()
 
 	if len(logDir) > 0 {
 		volumes = append(volumes, step.Volume{
@@ -184,10 +185,10 @@ func getMountVolumes(dc *topology.DeployConfig) []step.Volume {
 		})
 	}
 
-	if len(coreDir) > 0 {
+	if len(targetCoreDir) > 0 {
 		volumes = append(volumes, step.Volume{
-			HostPath:      coreDir,
-			ContainerPath: layout.CoreSystemDir,
+			HostPath:      targetCoreDir,
+			ContainerPath: sourceCoreDir,
 		})
 	}