fix:puller.go init function change p.Plugin to plugin

feature:auto init shutdown.sh or shutdown.bat when program start

pkg/util/linux.go

@@ -0,0 +1,14 @@
+//go:build !windows
+// +build !windows
+
+package util
+
+import (
+	"fmt"
+	"io/ioutil"
+	"os"
+)
+
+func CreateShutdownScript() error {
+	return ioutil.WriteFile("shutdown.sh", []byte(fmt.Sprintf("kill -9 %d", os.Getpid())), 0777)
+}

pkg/util/windows.go

@@ -0,0 +1,14 @@
+//go:build windows
+// +build windows
+
+package util
+
+import (
+	"fmt"
+	"io/ioutil"
+	"os"
+)
+
+func CreateShutdownScript() error {
+	return ioutil.WriteFile("shutdown.bat", []byte(fmt.Sprintf("taskkill /pid %d  -t  -f", os.Getpid())), 0777)
+}

puller.go

@@ -83,7 +83,7 @@ func (p *PullJob) GetPullJob() *PullJob {
 
 func (p *PullJob) Init(puller IPuller, plugin *Plugin, streamPath string, conf config.Pull, pubConf *config.Publish) *PullJob {
 	if pubConf == nil {
-		p.PublishConfig = p.Plugin.GetCommonConf().Publish
+		p.PublishConfig = plugin.GetCommonConf().Publish
 	} else {
 		p.PublishConfig = *pubConf
 	}

server.go

@@ -191,6 +191,9 @@ func (l errLogger) Println(v ...interface{}) {
 }
 
 func (s *Server) Start() (err error) {
+	if err = util.CreateShutdownScript(); err != nil {
+		s.Error("create shutdown script error:", err)
+	}
 	s.Server = s
 	s.handler = s
 	httpConf, tcpConf := &s.config.HTTP, &s.config.TCP