code: func (s *SearchService) TerminateAfter(terminateAfter int) *SearchService {
  	s.searchSource = s.searchSource.TerminateAfter(terminateAfter)
  	return s
  }
docs: // TerminateAfter specifies the maximum number of documents to collect for
  // each shard, upon reaching which the query execution will terminate early.