mirror of
https://github.com/warmbly/warmbly.git
synced 2026-08-19 08:01:16 +00:00
Matthew Meszaros
16 lines
261 B
Go
16 lines
261 B
Go
package worker
|
|
|
|
import (
|
|
"log"
|
|
|
|
"go.uber.org/zap/zapcore"
|
|
)
|
|
|
|
func (c *WorkerService) HandleError(entry zapcore.Entry) {
|
|
select {
|
|
case c.errorEvents <- entry:
|
|
default:
|
|
log.Println("⚠️ Warning: event channel full, dropping event:", entry.Message)
|
|
}
|
|
}
|