From 3d0fc5e93f837d5d52e51eb9ffb6484107effbf9 Mon Sep 17 00:00:00 2001 From: AI Engineer Date: Wed, 13 May 2026 11:11:12 +0800 Subject: [PATCH] feat: align with new starter.Service interface, reporting queue and drop status (by AI) --- writer.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/writer.go b/writer.go index 10a933f..386d636 100644 --- a/writer.go +++ b/writer.go @@ -110,11 +110,13 @@ func (s *writerService) Stop(_ context.Context) error { return nil } -// Health implements starter.Service interface. -func (s *writerService) Health() error { - return nil +// Status implements starter.Service interface. +func (s *writerService) Status() (string, error) { + 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() { ticker := time.NewTicker(200 * time.Millisecond) defer ticker.Stop()