MCPcopy
hub / github.com/elastic/go-elasticsearch / handleError

Method handleError

esutil/bulk_indexer.go:836–841  ·  view source on GitHub ↗
(ctx context.Context, err error)

Source from the content-addressed store, hash-verified

834}
835
836func (w *worker) handleError(ctx context.Context, err error) {
837 if w.bi.config.OnError != nil {
838 w.bi.config.OnError(ctx, err)
839 }
840 w.notifyItemsOnError(err)
841}
842
843type defaultJSONDecoder struct{}
844

Callers 1

flushBufferMethod · 0.95

Calls 1

notifyItemsOnErrorMethod · 0.95

Tested by

no test coverage detected