代码拉取完成,页面将自动刷新
package main
import "github.com/astaxie/beego"
import "github.com/astaxie/beego/plugins/cors"
import "gitee.com/humpbacks/common/models"
import "gitee.com/humpbacks/humpback-agent/config"
import "gitee.com/humpbacks/humpback-agent/controllers"
import "gitee.com/humpbacks/humpback-agent/routers"
import "gitee.com/humpbacks/humpback-center/cluster/types"
import (
"os"
"os/signal"
"syscall"
)
func main() {
config.Init()
config.SetVersion("1.3.7")
controllers.Init()
var conf = config.GetConfig()
beego.BConfig.MaxMemory = conf.DockerComposePackageMaxSize
composeStorage, err := models.NewComposeStorage(conf.DockerComposePath)
if err != nil {
beego.Error("compose storage error, " + err.Error())
return
}
routers.Init(composeStorage)
beego.InsertFilter("*", beego.BeforeRouter, cors.Allow(&cors.Options{
AllowOrigins: []string{"*"},
AllowMethods: []string{"GET", "POST", "PUT", "DELETE"},
AllowHeaders: []string{"Origin", "Accept", "Content-Type", "Authorization"},
AllowCredentials: true,
}))
beego.SetLogFuncCall(true)
beego.SetLevel(conf.LogLevel)
ipAddr, bindPort, err := config.GetNodeHTTPAddrIPPort()
if err != nil {
beego.Error("agent httpaddr error:" + err.Error())
}
beego.BConfig.Listen.HTTPPort = bindPort
if conf.DockerClusterEnabled {
clusterOptions := types.NewNodeRegisterOptions(ipAddr, bindPort, &conf)
if err := types.NodeRegister(clusterOptions); err != nil {
beego.Error("cluster node register error:" + err.Error())
return
}
}
go signalListen()
beego.Run()
}
func signalListen() {
c := make(chan os.Signal)
signal.Notify(c, syscall.SIGINT, syscall.SIGTERM)
for {
<-c
types.NodeClose()
os.Exit(0)
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。