code: func (s *RPC) SendConsensus(destination uint64, msg *orderer.ConsensusRequest) error {
  	if s.Logger.IsEnabledFor(zapcore.DebugLevel) {
  		defer s.consensusSent(time.Now(), destination, msg)
  	}
  
  	stream, err := s.getOrCreateStream(destination, ConsensusOperation)
  	if err != nil {
  		return err
  	}
  
  	req := &orderer.StepRequest{
  		Payload: &orderer.StepRequest_ConsensusRequest{
  			ConsensusRequest: msg,
  		},
  	}
  
  	s.consensusLock.Lock()
  	defer s.consensusLock.Unlock()
  
  	err = stream.Send(req)
  	if err != nil {
  		s.unMapStream(destination, ConsensusOperation)
  	}
  
  	return err
  }
docs: // Consensus passes the given ConsensusRequest message to the raft.Node instance.