(err error)
| 826 | } |
| 827 | |
| 828 | func (w *worker) notifyItemsOnError(err error) { |
| 829 | for _, item := range w.items { |
| 830 | if item.OnFailure != nil { |
| 831 | item.OnFailure(item.ctx, item, BulkIndexerResponseItem{}, err) |
| 832 | } |
| 833 | } |
| 834 | } |
| 835 | |
| 836 | func (w *worker) handleError(ctx context.Context, err error) { |
| 837 | if w.bi.config.OnError != nil { |