go/starter
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

publish v1.5.1

Browse Source
This commit is contained in:
AI Engineer 2026-06-05 01:12:22 +08:00
parent f082e879c1
commit 904f2b29d2
1 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
starter.go
View File

@ -243,8 +243,11 @@ func startServices(ctx context.Context) error {
sctx, cancel = context.WithTimeout(ctx, ms.startTimeout)
defer cancel()
}
logger.Info(fmt.Sprintf("service [%s] starting", ms.Name))
if err := ms.svc.Start(sctx, logger); err != nil {
errChan <- fmt.Errorf("service [%s] start error: %w", ms.Name, err)
} else {
logger.Info(fmt.Sprintf("service [%s] started", ms.Name))
}
}(ms)
}
@ -264,6 +267,9 @@ func stopServices() {
sort.Slice(startedPriorities, func(i, j int) bool {
return startedPriorities[i] > startedPriorities[j]
})
logger := log.DefaultLogger.New(id.Get8Bytes4KPerSecond())
for _, p := range startedPriorities {
svcs := services[p]
var wg sync.WaitGroup
@ -277,8 +283,11 @@ func stopServices() {
sctx, cancel = context.WithTimeout(sctx, ms.stopTimeout)
defer cancel()
}
logger.Info(fmt.Sprintf("service [%s] stopping", ms.Name))
if err := ms.svc.Stop(sctx); err != nil {
log.DefaultLogger.Error(fmt.Sprintf("service [%s] stop error: %v", ms.Name, err))
logger.Error(fmt.Sprintf("service [%s] stop error: %v", ms.Name, err))
} else {
logger.Info(fmt.Sprintf("service [%s] stopped", ms.Name))
}
}(ms)
}