code: func (p *BulkProcessor) Stats() BulkProcessorStats {
  	p.statsMu.Lock()
  	defer p.statsMu.Unlock()
  	return *p.stats.dup()
  }
docs: // Stats returns the latest bulk processor statistics.
  // Collecting stats must be enabled first by calling Stats(true) on
  // the service that created this processor.