ostiwe-com/status
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases 1 Wiki Activity

refactor: Update startup server

Browse Source
This commit is contained in:
Nikolay Anoshin
2025-10-28 00:52:09 +03:00
parent b33df27b31
commit 628abc4d11
1 changed files with 20 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
server/server.go
View File

@@ -1,14 +1,16 @@
package server package server
import ( import (
"context"
"fmt" "fmt"
"net/http" "net/http"
"git.ostiwe.com/ostiwe-com/status/modules/db" "git.ostiwe.com/ostiwe-com/status/modules/db"
appLog "git.ostiwe.com/ostiwe-com/status/modules/log" appLog "git.ostiwe.com/ostiwe-com/status/modules/log"
"git.ostiwe.com/ostiwe-com/status/modules/queue" "git.ostiwe.com/ostiwe-com/status/modules/scheduler"
"git.ostiwe.com/ostiwe-com/status/pkg/args" "git.ostiwe.com/ostiwe-com/status/pkg/args"
"git.ostiwe.com/ostiwe-com/status/router" "git.ostiwe.com/ostiwe-com/status/router"
"git.ostiwe.com/ostiwe-com/status/service"
"github.com/sirupsen/logrus" "github.com/sirupsen/logrus"
) )
@@ -21,8 +23,24 @@ func Run(serverArgs *args.ServerCmd) {
db.SetGlobal(connect) db.SetGlobal(connect)
scheduler.GlobalAppScheduler, err = scheduler.NewAppScheduler()
if err != nil {
appLog.Global.Get(appLog.SYSTEM).Error(fmt.Sprintf("Startup server error, failed create scheduler: %v", err))
return
}
appLog.Global.Get(appLog.SYSTEM).Info("Start service observer") appLog.Global.Get(appLog.SYSTEM).Info("Start service observer")
go queue.InitQueues() service.GlobalCheckService = service.NewCheck(scheduler.GlobalAppScheduler)
if err = service.GlobalCheckService.RegisterTasks(context.Background()); err != nil {
appLog.Global.Get(appLog.SYSTEM).Error(fmt.Sprintf("Startup server error, failed create observe jobs: %v", err))
return
}
if err = scheduler.GlobalAppScheduler.StartJobs(); err != nil {
appLog.Global.Get(appLog.SYSTEM).Error(fmt.Sprintf("Startup server error, failed start jobs: %v", err))
return
}
appLog.Global.Put(appLog.SERVER, logrus.New()) appLog.Global.Put(appLog.SERVER, logrus.New())
appLog.Global.Get(appLog.SERVER).Info("Startup server on port: ", serverArgs.Port) appLog.Global.Get(appLog.SERVER).Info("Startup server on port: ", serverArgs.Port)