(ctx context.Context)
| 175 | } |
| 176 | |
| 177 | func (r *ReindexService) createCollections(ctx context.Context) error { |
| 178 | r.updateProgress("create_collections", 0, 0) |
| 179 | logrus.Info("Creating collections") |
| 180 | |
| 181 | if err := r.client.EnsureCollectionsExist(ctx); err != nil { |
| 182 | return err |
| 183 | } |
| 184 | |
| 185 | logrus.Info("All collections created successfully") |
| 186 | return nil |
| 187 | } |
| 188 | |
| 189 | func (r *ReindexService) indexLedgers(ctx context.Context) error { |
| 190 | r.updateProgress("indexing_ledgers", 0, 0) |
no test coverage detected