Method flush

esutil/bulk_indexer.go:672–679

flush writes out the worker buffer and handles errors. It also restarts the ticker. Returns true to indicate success.

(ctx context.Context)

// It also restarts the ticker.
// Returns true to indicate success.
func (w *worker) flush(ctx context.Context) bool {
	ok := true
	if err := w.flushBuffer(ctx); err != nil {
		ok = false
	}
	w.ticker.Reset(w.bi.nextFlushInterval())
	return ok
}

// flushBuffer writes out the worker buffer.
//