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

feat: align with new starter.Service interface, reporting queue and drop status (by AI)

Browse Source
This commit is contained in:
AI Engineer 2026-05-13 11:11:12 +08:00
parent 1f816dc8b3
commit 3d0fc5e93f
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
writer.go
View File

@ -110,11 +110,13 @@ func (s *writerService) Stop(_ context.Context) error {
return nil return nil
} }
// Health implements starter.Service interface. // Status implements starter.Service interface.
func (s *writerService) Health() error { func (s *writerService) Status() (string, error) {
return nil if s.Running.Load() {
return fmt.Sprintf("queue: %d, dropped: %d", len(s.LogChannel), s.Dropped.Load()), nil
}
return "stopped", nil
} }
func (s *writerService) writerRunner() { func (s *writerService) writerRunner() {
ticker := time.NewTicker(200 * time.Millisecond) ticker := time.NewTicker(200 * time.Millisecond)
defer ticker.Stop() defer ticker.Stop()