(ctx context.Context)
| 163 | } |
| 164 | |
| 165 | func (r *ReindexService) dropCollections(ctx context.Context) error { |
| 166 | r.updateProgress("drop_collections", 0, 0) |
| 167 | logrus.Info("Dropping all collections") |
| 168 | |
| 169 | if err := r.client.DropAllCollections(ctx); err != nil { |
| 170 | return err |
| 171 | } |
| 172 | |
| 173 | logrus.Info("All collections dropped successfully") |
| 174 | return nil |
| 175 | } |
| 176 | |
| 177 | func (r *ReindexService) createCollections(ctx context.Context) error { |
| 178 | r.updateProgress("create_collections", 0, 0) |
no test coverage detected