Method Set

pkg/task/queue/queue_storage.go:41–46

Set stores a queue with the given name

(name string, queue *TaskQueue)

// Set stores a queue with the given name
func (qs *queueStorage) Set(name string, queue *TaskQueue) {
	qs.mu.Lock()
	defer qs.mu.Unlock()

	qs.queues[name] = queue
}

// Delete removes a queue by name
func (qs *queueStorage) Delete(name string) {