code: func OptSrcBufSize(bufsize int) SrcOption {
  	return func(s *Source) {
  		s.records = make(chan map[string]interface{}, bufsize)
  	}
  }
docs: // OptSrcBufSize sets the number of records to buffer while waiting for Record
  // to be called.