code: func (d *distributorImpl) Distribute(txID string, privData *transientstore.TxPvtReadWriteSetWithConfigInfo, blkHt uint64) error {
  	disseminationPlan, err := d.computeDisseminationPlan(txID, privData, blkHt)
  	if err != nil {
  		return errors.WithStack(err)
  	}
  	return d.disseminate(disseminationPlan)
  }
docs: // Distribute broadcast reliably private data read write set based on policies