add main pkg

.idea/.gitignore

+# 默认忽略的文件
+/shelf/
+/workspace.xml
+# 数据源本地存储已忽略文件
+/dataSources/
+/dataSources.local.xml
+# 基于编辑器的 HTTP 客户端请求
+/httpRequests/

.idea/goactuator.iml

+<?xml version="1.0" encoding="UTF-8"?>
+<module type="WEB_MODULE" version="4">
+  <component name="Go" enabled="true" />
+  <component name="NewModuleRootManager">
+    <content url="file://$MODULE_DIR$" />
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+  </component>
+</module>
\ No newline at end of file

.idea/modules.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectModuleManager">
+    <modules>
+      <module fileurl="file://$PROJECT_DIR$/.idea/goactuator.iml" filepath="$PROJECT_DIR$/.idea/goactuator.iml" />
+    </modules>
+  </component>
+</project>
\ No newline at end of file

.idea/vcs.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="VcsDirectoryMappings">
+    <mapping directory="$PROJECT_DIR$" vcs="Git" />
+  </component>
+</project>
\ No newline at end of file

src/2021-10-26.log

+<actuator>2021/10/26 18:09:29 main.go:20: getRunnableSlotList error:got null address
+<actuator>2021/10/26 18:09:29 main.go:46: getRunnableDaemonList error:got null address
+<actuator>2021/10/26 18:09:29 main.go:72: getTerminatedDaemonList error:got null address

src/actuator/actuatotFeatures.go

@@ -2,6 +2,7 @@ package actuator
 
 import (
 	"context"
+	"errors"
 	"github.com/golang/protobuf/ptypes/empty"
 	wrps "github.com/golang/protobuf/ptypes/wrappers"
 	pb "goactuator/scalebox"
@@ -16,10 +17,12 @@ var address =os.Getenv("grpc_server")
 var logger,_= MakeLog("./")
 
 
-func GetRunnableSlotList() ([]*pb.Command,error) {
-	//test
-	address =os.Getenv("grpc_server")
 
+func GetRunnableSlotList() ([]*pb.Command,error) {
+	//avoid grpc panic due to get null ip addr
+	if address==""{
+		return nil,errors.New("got null server address")
+	}
 	//connecting
 	conn, err := grpc.Dial(address, grpc.WithInsecure())
 	if err != nil {
@@ -40,6 +43,10 @@ func GetRunnableSlotList() ([]*pb.Command,error) {
 }
 
 func GetRunnableDaemonList() ([]*pb.Command,error) {
+	//avoid grpc panic due to get null ip addr
+	if address==""{
+		return nil,errors.New("got null server address")
+	}
 	//connecting
 	conn, err := grpc.Dial(address, grpc.WithInsecure())
 	if err != nil {
@@ -59,6 +66,10 @@ func GetRunnableDaemonList() ([]*pb.Command,error) {
 }
 
 func GetTerminatedDaemonList()  ([]*pb.Command,error) {
+	//avoid grpc panic due to get null ip addr
+	if address==""{
+		return nil,errors.New("got null server address")
+	}
 	//connecting
 	conn, err := grpc.Dial(address, grpc.WithInsecure())
 	if err != nil {
@@ -84,6 +95,10 @@ func GetTerminatedDaemonList()  ([]*pb.Command,error) {
 
 func SetSlotInitialized(cmdPkg *pb.Command)error  {
 
+	//avoid grpc panic due to get null ip addr
+	if address==""{
+		return errors.New("got null server address")
+	}
 	//connecting
 	conn, err := grpc.Dial(address, grpc.WithInsecure())
 	if err != nil {
@@ -106,6 +121,10 @@ func SetSlotInitialized(cmdPkg *pb.Command)error  {
 
 
 func SetRunnableDaemonInitialized(cmdPkg *pb.Command)error  {
+	//avoid grpc panic due to get null ip addr
+	if address==""{
+		return errors.New("got null server address")
+	}
 	//connecting
 	conn, err := grpc.Dial(address, grpc.WithInsecure())
 	if err != nil {
@@ -126,6 +145,10 @@ func SetRunnableDaemonInitialized(cmdPkg *pb.Command)error  {
 }
 
 func SetRunnableDaemonTerminated(cmdPkg *pb.Command)error{
+	//avoid grpc panic due to get null ip addr
+	if address==""{
+		return errors.New("got null address")
+	}
 	//connecting
 	conn, err := grpc.Dial(address, grpc.WithInsecure())
 	if err != nil {

src/main/2021-10-26.log

+<actuator>2021/10/26 18:15:25 main.go:20: getRunnableSlotList error:got null address
+<actuator>2021/10/26 18:15:25 main.go:46: getRunnableDaemonList error:got null address
+<actuator>2021/10/26 18:15:25 main.go:72: getTerminatedDaemonList error:got null address

src/main/main.go

@@ -13,6 +13,7 @@ var logger,_= MakeLog("./")
 func main()  {
 	for {
 
+		log.Println("<actuator>:Getting SlotList>>>")
 		commandList, err :=GetRunnableSlotList()
 		if err != nil {
 			log.Printf("getRunnableSlotList error:%v", err)
@@ -38,6 +39,7 @@ func main()  {
 			}
 		}
 
+		log.Println("<actuator>:Getting DaemonList>>>")
 		commandList,err=GetRunnableDaemonList()
 		if err != nil {
 			log.Printf("getRunnableDaemonList error:%v", err)
@@ -63,10 +65,11 @@ func main()  {
 			}
 		}
 
+		log.Println("<actuator>:Getting Daemon2TerminatedList>>>")
 		commandList,err=GetTerminatedDaemonList()
 		if err != nil {
 			log.Printf("getTerminatedDaemonList error:%v", err)
-			logger.Fatalf("getTerminatedDaemonList error:%v", err)
+			logger.Printf("getTerminatedDaemonList error:%v", err)
 		}else {
 
 			if len(commandList) != 0 {
@@ -87,8 +90,7 @@ func main()  {
 				}
 			}
 		}
-
-
+		log.Println("Going to sleep for 2m")
 		time.Sleep(time.Second*120)
 	}