spec: fix CI errors

pkg/cluster/spec/grafana.go

@@ -192,7 +192,7 @@ func (i *GrafanaInstance) InitConfig(
 	if (val == reflect.Value{}) {
 		return errors.Errorf("field Monitors not found in topology: %v", topo)
 	}
-	monitors := val.Interface().([]PrometheusSpec)
+	monitors := val.Interface().([]*PrometheusSpec)
 	// transfer datasource.yml
 	if len(monitors) == 0 {
 		return errors.New("no prometheus found in topology")

pkg/cluster/spec/parse_topology.go

@@ -74,7 +74,7 @@ func ExpandRelativeDir(topo Topology) {
 }
 
 func expandRelativePath(user string, topo interface{}) {
-	v := reflect.ValueOf(topo).Elem()
+	v := reflect.Indirect(reflect.ValueOf(topo).Elem())
 
 	switch v.Kind() {
 	case reflect.Slice:

pkg/cluster/spec/prometheus.go

@@ -240,16 +240,16 @@ func (i *MonitorInstance) InitConfig(
 	}
 	if servers, found := topoHasField("Masters"); found {
 		for i := 0; i < servers.Len(); i++ {
-			master := servers.Index(i)
+			master := reflect.Indirect(servers.Index(i))
 			host, port := master.FieldByName("Host").String(), master.FieldByName("Port").Int()
 			cfig.AddDMMaster(host, uint64(port))
 		}
 	}
 
 	if servers, found := topoHasField("Workers"); found {
 		for i := 0; i < servers.Len(); i++ {
-			master := servers.Index(i)
-			host, port := master.FieldByName("Host").String(), master.FieldByName("Port").Int()
+			worker := reflect.Indirect(servers.Index(i))
+			host, port := worker.FieldByName("Host").String(), worker.FieldByName("Port").Int()
 			cfig.AddDMWorker(host, uint64(port))
 		}
 	}

pkg/cluster/spec/spec.go

@@ -494,11 +494,11 @@ func setCustomDefaults(globalOptions *GlobalOptions, field reflect.Value) error
 			if field.Field(j).String() != "" {
 				continue
 			}
-			host := field.FieldByName("Host").String()
-			clientPort := field.FieldByName("ClientPort").Int()
+			host := reflect.Indirect(field).FieldByName("Host").String()
+			clientPort := reflect.Indirect(field).FieldByName("ClientPort").Int()
 			field.Field(j).Set(reflect.ValueOf(fmt.Sprintf("pd-%s-%d", host, clientPort)))
 		case "DataDir":
-			if field.FieldByName("Imported").Interface().(bool) {
+			if reflect.Indirect(field).FieldByName("Imported").Interface().(bool) {
 				setDefaultDir(globalOptions.DataDir, field.Addr().Interface().(InstanceSpec).Role(), getPort(field), field.Field(j))
 			}
 

pkg/cluster/spec/tispark.go

@@ -171,7 +171,7 @@ type TiSparkMasterInstance struct {
 
 // GetCustomFields get custom spark configs of the instance
 func (i *TiSparkMasterInstance) GetCustomFields() map[string]interface{} {
-	v := reflect.ValueOf(i.InstanceSpec).FieldByName("SparkConfigs")
+	v := reflect.Indirect(reflect.ValueOf(i.InstanceSpec)).FieldByName("SparkConfigs")
 	if !v.IsValid() {
 		return nil
 	}
@@ -180,7 +180,7 @@ func (i *TiSparkMasterInstance) GetCustomFields() map[string]interface{} {
 
 // GetCustomEnvs get custom spark envionment variables of the instance
 func (i *TiSparkMasterInstance) GetCustomEnvs() map[string]string {
-	v := reflect.ValueOf(i.InstanceSpec).FieldByName("SparkEnvs")
+	v := reflect.Indirect(reflect.ValueOf(i.InstanceSpec)).FieldByName("SparkEnvs")
 	if !v.IsValid() {
 		return nil
 	}
@@ -189,7 +189,7 @@ func (i *TiSparkMasterInstance) GetCustomEnvs() map[string]string {
 
 // GetJavaHome returns the java_home value in spec
 func (i *TiSparkMasterInstance) GetJavaHome() string {
-	return reflect.ValueOf(i.InstanceSpec).FieldByName("JavaHome").String()
+	return reflect.Indirect(reflect.ValueOf(i.InstanceSpec)).FieldByName("JavaHome").String()
 }
 
 // InitConfig implement Instance interface
@@ -338,7 +338,7 @@ type TiSparkWorkerInstance struct {
 
 // GetJavaHome returns the java_home value in spec
 func (i *TiSparkWorkerInstance) GetJavaHome() string {
-	return reflect.ValueOf(i.InstanceSpec).FieldByName("JavaHome").String()
+	return reflect.Indirect(reflect.ValueOf(i.InstanceSpec)).FieldByName("JavaHome").String()
 }
 
 // InitConfig implement Instance interface