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

Method Flush

esutil/bulk_indexer.go:75–75  ·  view source on GitHub ↗

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)

Source from the content-addressed store, hash-verified

73 //
74 // It is safe for concurrent use with Add.
75 Flush(context.Context) error
76
77 // Stats returns indexer statistics.
78 Stats() BulkIndexerStats

Callers 2

TestBulkIndexerFlushFunction · 0.95
ExampleBulkIndexer_FlushFunction · 0.95

Implementers 1

bulkIndexeresutil/bulk_indexer.go

Calls

no outgoing calls

Tested by 2

TestBulkIndexerFlushFunction · 0.76
ExampleBulkIndexer_FlushFunction · 0.76