dermesser
0 Likes Commentsgolang
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")}
}