(tenantID string)
| 125 | } |
| 126 | |
| 127 | func (f *generatorForwarder) getQueue(tenantID string) (*queue.Queue[*request], bool) { |
| 128 | f.mutex.RLock() |
| 129 | defer f.mutex.RUnlock() |
| 130 | |
| 131 | q, ok := f.queues[tenantID] |
| 132 | return q, ok |
| 133 | } |
| 134 | |
| 135 | // watchOverrides watches the overrides for changes |
| 136 | // and updates the queues accordingly |