in bulk_indexer.go [247:254]
func (b *BulkIndexer) resetBuf() { b.itemsAdded = 0 b.writer.bytesWritten = 0 b.buf.Reset() if b.gzipw != nil { b.gzipw.Reset(&b.buf) } }