in bulk_indexer.go [197:200]
func (cw *countWriter) Write(p []byte) (int, error) { cw.bytesWritten += len(p) return cw.Writer.Write(p) }