package consul import ( "net" ) // Raft endpoint is used to manipulate the Raft subsystem type Raft struct { server *Server } func (r *Raft) RemovePeer(args string, reply *struct{}) error { peer, err := net.ResolveTCPAddr("tcp", args) if err != nil { r.server.logger.Printf("[ERR] consul.raft: failed to parse peer: %v", err) return err } future := r.server.raft.RemovePeer(peer) return future.Error() } func (r *Raft) Snapshot(args struct{}, reply *struct{}) error { future := r.server.raft.Snapshot() return future.Error() }