GetProgressPtr returns a pointer to the current progress.
()
| 143 | |
| 144 | // GetProgressPtr returns a pointer to the current progress. |
| 145 | func (r *ReindexService) GetProgressPtr() *ReindexProgress { |
| 146 | r.mu.RLock() |
| 147 | defer r.mu.RUnlock() |
| 148 | progress := *r.progress |
| 149 | return &progress |
| 150 | } |
| 151 | |
| 152 | func (r *ReindexService) failWithError(err error, phase string) (*ReindexProgress, error) { |
| 153 | r.mu.Lock() |
no outgoing calls
no test coverage detected