(dbName string, reason string)
| 172 | } |
| 173 | |
| 174 | func (m *DatabaseInitManager) Cancel(dbName string, reason string) { |
| 175 | m.workersLock.Lock() |
| 176 | defer m.workersLock.Unlock() |
| 177 | worker, ok := m.workers[dbName] |
| 178 | if !ok { |
| 179 | return |
| 180 | } |
| 181 | worker.Stop(reason) |
| 182 | } |
| 183 | |
| 184 | // buildCollectionIndexData determines the set of indexes required for each collection in the config, including |
| 185 | // the metadata collection |
no test coverage detected