main.go 1.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748
  1. package main
  2. /*
  3. 1. 算法清理可以用仿真云平台的调度系统
  4. */
  5. import (
  6. "cicv-data-closedloop/amd64/kubernetes-scheduler/package/handler"
  7. "cicv-data-closedloop/common/config/c_log"
  8. "cicv-data-closedloop/common/config/c_nacos"
  9. "cicv-data-closedloop/common/config/c_oss"
  10. commonHandler "cicv-data-closedloop/common/gin/handler"
  11. "cicv-data-closedloop/common/util"
  12. "github.com/gin-gonic/gin"
  13. "os"
  14. )
  15. const (
  16. servicePort = 12341
  17. serviceName = "kubernetes-scheduler"
  18. routerPrefix = "/cicv-data-closedloop/kubernetes-scheduler/"
  19. configDataId = "kubernetes-scheduler-prod.yaml"
  20. configGroup = "DEFAULT_GROUP"
  21. )
  22. func init() {
  23. c_log.InitLog("kubernetes-scheduler")
  24. c_log.InitLog(serviceName)
  25. c_oss.InitOss(false)
  26. c_nacos.InitService(false, serviceName, servicePort, map[string]string{
  27. "开发者": "孟令鑫",
  28. "内网IP": "10.14.85.228",
  29. "外网IP": "36.110.106.156",
  30. })
  31. c_nacos.InitConfig(false, configDataId, configGroup)
  32. }
  33. func main() {
  34. router := gin.Default()
  35. router.Use(commonHandler.ValidateHeaders())
  36. api := router.Group(routerPrefix)
  37. api.POST("/start-project", handler.StartProject)
  38. err := router.Run()
  39. if err != nil {
  40. c_log.GlobalLogger.Error("程序崩溃,监听端口 " + util.ToString(servicePort) + " 失败。")
  41. os.Exit(-1)
  42. }
  43. }