jiazhizhong/polaris
1
0
Fork 0
mirror of https://github.com/simon-ding/polaris.git synced 2026-06-26 02:34:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: add log and defer task loading

Browse Source
This commit is contained in:
Simon Ding
2024-11-04 12:04:28 +08:00
parent 1e2d8b8520
commit b176253fc4
3 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/core/client.go
View File

@@ -44,7 +44,7 @@ func (c *Client) registerCronJob(name string, cron string, f func() error) {
} }
func (c *Client) Init() { func (c *Client) Init() {
c.reloadTasks() go c.reloadTasks()
c.addSysCron() c.addSysCron()
} }
@@ -82,6 +82,7 @@ func (c *Client) reloadTasks() {
} }
} }
log.Infof("------ task reloading done ------")
} }
func (c *Client) GetDownloadClient() (pkg.Downloader, *ent.DownloadClients, error) { func (c *Client) GetDownloadClient() (pkg.Downloader, *ent.DownloadClients, error) {

1
server/core/scheduler.go
View File

@@ -36,6 +36,7 @@ func (c *Client) addSysCron() {
return true return true
}) })
c.cron.Start() c.cron.Start()
log.Infof("--------- add cron jobs done --------")
} }
func (c *Client) mustAddCron(spec string, cmd func()) { func (c *Client) mustAddCron(spec string, cmd func()) {

1
server/server.go
View File

@@ -132,6 +132,7 @@ func (s *Server) Serve() error {
importlist.POST("/add", HttpHandler(s.addImportlist)) importlist.POST("/add", HttpHandler(s.addImportlist))
importlist.DELETE("/delete", HttpHandler(s.deleteImportList)) importlist.DELETE("/delete", HttpHandler(s.deleteImportList))
} }
log.Infof("----------- Polaris Server Successfully Started ------------")
return s.r.Run(":8080") return s.r.Run(":8080")
} }