refactor: migrate all log statements to structured logger calls for improved observability
This commit is contained in:
@@ -68,7 +68,7 @@ func (p *WorkerPool) Start() {
|
||||
p.wg.Add(1)
|
||||
go p.workerLoop(i)
|
||||
}
|
||||
logger.Log.Infof("[WorkerPool] Started %d workers", p.workerCount)
|
||||
logger.Log.Infow("Started workers", "component", "WorkerPool", "count", p.workerCount)
|
||||
}
|
||||
|
||||
func (p *WorkerPool) Stop() {
|
||||
@@ -78,22 +78,22 @@ func (p *WorkerPool) Stop() {
|
||||
p.cancel()
|
||||
p.isRunning.Store(false)
|
||||
p.wg.Wait()
|
||||
logger.Log.Infof("[WorkerPool] All workers stopped")
|
||||
logger.Log.Infow("All workers stopped", "component", "WorkerPool")
|
||||
}
|
||||
|
||||
func (p *WorkerPool) workerLoop(workerID int) {
|
||||
defer p.wg.Done()
|
||||
logger.Log.Debugf("[Worker %d] Starting loop", workerID)
|
||||
logger.Log.Debugw("Starting loop", "component", "Worker", "worker_id", workerID)
|
||||
|
||||
for {
|
||||
select {
|
||||
case <-p.ctx.Done():
|
||||
logger.Log.Debugf("[Worker %d] Context cancelled, exiting", workerID)
|
||||
logger.Log.Debugw("Context cancelled, exiting", "component", "Worker", "worker_id", workerID)
|
||||
return
|
||||
default:
|
||||
task, err := p.db.ClaimNextTask()
|
||||
if err != nil {
|
||||
logger.Log.Errorf("[Worker %d] Error claiming task: %v", workerID, err)
|
||||
logger.Log.Errorw("Error claiming task", "component", "Worker", "worker_id", workerID, "error", err)
|
||||
time.Sleep(1 * time.Second)
|
||||
continue
|
||||
}
|
||||
@@ -104,7 +104,7 @@ func (p *WorkerPool) workerLoop(workerID int) {
|
||||
continue
|
||||
}
|
||||
|
||||
logger.Log.Debugf("[Worker %d] Picked up task %d (%s)", workerID, task.ID, task.TaskType)
|
||||
logger.Log.Debugw("Picked up task", "component", "Worker", "worker_id", workerID, "task_id", task.ID, "task_type", task.TaskType)
|
||||
|
||||
// Process task based on type
|
||||
var processErr error
|
||||
@@ -122,10 +122,10 @@ func (p *WorkerPool) workerLoop(workerID int) {
|
||||
}
|
||||
|
||||
if processErr != nil {
|
||||
logger.Log.Errorf("[Worker %d] Task %d FAILED: %v", workerID, task.ID, processErr)
|
||||
logger.Log.Errorw("Task FAILED", "component", "Worker", "worker_id", workerID, "task_id", task.ID, "error", processErr)
|
||||
_ = p.db.FailTask(task.ID, processErr.Error())
|
||||
} else {
|
||||
logger.Log.Debugf("[Worker %d] Task %d COMPLETED", workerID, task.ID)
|
||||
logger.Log.Debugw("Task COMPLETED", "component", "Worker", "worker_id", workerID, "task_id", task.ID)
|
||||
_ = p.db.CompleteTask(task.ID)
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user