(id string, name string, err error)
| 261 | } |
| 262 | |
| 263 | func (i *IndexLocker) Error(id string, name string, err error) { |
| 264 | if err == nil { |
| 265 | return |
| 266 | } |
| 267 | i.Lock() |
| 268 | defer i.Unlock() |
| 269 | if names, nok := i.nodes[id]; nok { |
| 270 | if info, iok := names[name]; iok { |
| 271 | info.Error = err.Error() |
| 272 | logger.Error(fmt.Sprintf("error during asynchronous indexing node=%s, index=%s: %s", id, name, err.Error())) |
| 273 | } |
| 274 | } |
| 275 | } |
| 276 | |
| 277 | func (i *IndexLocker) Remove(id string, name string) { |
| 278 | i.Lock() |