Untitled

func (s *RpcServer) registerHandlers() {
  s.srv.RegisterHandler(RPC_SERVICE, "ConfigChange", s.ConfigRequestHandler)
  s.srv.RegisterHandler(RPC_SERVICE, "AppendEntries", s.AppendEntriesHandler)
	s.srv.RegisterHandler(RPC_SERVICE, "RequestVote", s.RequestVoteHandler)
	s.srv.RegisterHandler(RPC_SERVICE, "InstallSnapshot", s.InstallSnapshotHandler)
}

// Sends a request to the given processor. Returns nil if the processor doesn't exist.
func (s *RpcServer) sendRequest(cluster_id string, rq *RpcRequest) *RpcResponse {
	s.mx.Lock()
	defer s.mx.Unlock()

	c, ok := s.processors[cluster_id]

	if !ok {
		return &RpcResponse{err: errors.New("No such cluster")}
	}