Documentation
¶
Overview ¶
Package worker provides job processing functionality through concurrent worker goroutines. It handles job execution, retries, error recovery, and graceful shutdown while maintaining configurable concurrency limits and collecting performance metrics.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
Worker manages a pool of goroutines that process jobs from a queue. It handles job execution, retries, metrics collection, and graceful shutdown.
func NewWorker ¶
func NewWorker(store adapter.Store, config configuration.Config, queueName string, statsCollector *stats.Collector, logger logger.Logger) *Worker
NewWorker creates a new Worker instance with the specified configuration. It initializes the middleware chain, concurrency controls, and metrics collection.
Source Files
Click to show internal directories.
Click to hide internal directories.