worker

Nov 17, 2025

Changes in this version

+ const WorkerStatusFailed

+ const WorkerStatusHealthy

+ type HealthTracker struct

+ func NewHealthTracker() *HealthTracker

+ func (h *HealthTracker) GetStatus() map[string]interface{}

+ func (h *HealthTracker) IsHealthy() bool

+ func (h *HealthTracker) MarkFailed(name string)

+ func (h *HealthTracker) MarkHealthy(name string)

+ type Logger interface

+ Debug func(msg string, fields ...zap.Field)

+ Error func(msg string, fields ...zap.Field)

+ Info func(msg string, fields ...zap.Field)

+ Warn func(msg string, fields ...zap.Field)

+ type SupervisorOption func(*WorkerSupervisor)

+ func WithShutdownTimeout(timeout time.Duration) SupervisorOption

+ type Worker interface

+ Name func() string

+ Run func(ctx context.Context) error

+ type WorkerHealth struct

+ Status string

+ type WorkerSupervisor struct

+ func NewWorkerSupervisor(logger Logger, opts ...SupervisorOption) *WorkerSupervisor

+ func (r *WorkerSupervisor) GetHealthTracker() *HealthTracker

+ func (r *WorkerSupervisor) Register(w Worker)

+ func (r *WorkerSupervisor) Run(ctx context.Context) error