Method NewNamedQueue

pkg/task/queue/queue_set.go:91–108

(name string, handler func(ctx context.Context, t task.Task) TaskResult, opts ...TaskQueueOption)

}

func (tqs *TaskQueueSet) NewNamedQueue(name string, handler func(ctx context.Context, t task.Task) TaskResult, opts ...TaskQueueOption) {
	q := NewTasksQueue(
		name,
		tqs.metricStorage,
		WithHandler(handler),
		WithContext(tqs.ctx),
	)

	for _, opt := range opts {
		opt(q)
	}

	if q.logger == nil {
		q.logger = log.NewLogger().Named("task_queue")
	}

	tqs.Queues.Set(q.Name, q)
}

func (tqs *TaskQueueSet) GetByName(name string) *TaskQueue {
	q, ok := tqs.Queues.Get(name)