Flush drains all currently queued items, flushes all worker buffers to Elasticsearch, and waits for the flushes to complete. The indexer remains usable after Flush returns; new items may be added with Add. Per-item results are delivered through the OnSuccess and OnFailure callbacks on each BulkInde
(context.Context)
| 73 | // |
| 74 | // It is safe for concurrent use with Add. |
| 75 | Flush(context.Context) error |
| 76 | |
| 77 | // Stats returns indexer statistics. |
| 78 | Stats() BulkIndexerStats |
no outgoing calls