List retrieves all queues
()
| 26 | |
| 27 | // List retrieves all queues |
| 28 | func (qs *queueStorage) List() []*TaskQueue { |
| 29 | qs.mu.RLock() |
| 30 | defer qs.mu.RUnlock() |
| 31 | |
| 32 | queues := make([]*TaskQueue, 0, len(qs.queues)) |
| 33 | for _, queue := range qs.queues { |
| 34 | queues = append(queues, queue) |
| 35 | } |
| 36 | |
| 37 | return queues |
| 38 | } |
| 39 | |
| 40 | // Set stores a queue with the given name |
| 41 | func (qs *queueStorage) Set(name string, queue *TaskQueue) { |
no outgoing calls
no test coverage detected