(logger *log.Logger)
| 170 | } |
| 171 | |
| 172 | func WithLogger(logger *log.Logger) TaskQueueOption { |
| 173 | return func(q *TaskQueue) { |
| 174 | q.logger = logger |
| 175 | q.logger = q.logger.Named(q.Name) |
| 176 | } |
| 177 | } |
| 178 | |
| 179 | // NewTasksQueue creates a new TaskQueue with the provided options |
| 180 | func NewTasksQueue(name string, metricStorage metricsstorage.Storage, opts ...TaskQueueOption) *TaskQueue { |
no outgoing calls
no test coverage detected