Method moveTablet

dgraph/cmd/zero/http.go:141–206

moveTablet can be used to move a tablet to a specific group. It takes in tablet and group as argument.

(w http.ResponseWriter, r *http.Request)

// moveTablet can be used to move a tablet to a specific group. It takes in tablet and group as
// argument.
func (st *state) moveTablet(w http.ResponseWriter, r *http.Request) {
	x.AddCorsHeaders(w)
	if r.Method == "OPTIONS" {
		return
	}
	if r.Method != http.MethodGet {
		w.WriteHeader(http.StatusBadRequest)
		x.SetStatus(w, x.ErrorInvalidMethod, "Invalid method")
		return
	}

	if !st.node.AmLeader() {
		w.WriteHeader(http.StatusBadRequest)
		x.SetStatus(w, x.ErrorInvalidRequest,
			"This Zero server is not the leader. Re-run command on leader.")
		return
	}

	namespace := r.URL.Query().Get("namespace")
	namespace = strings.TrimSpace(namespace)
	ns := x.RootNamespace
	if namespace != "" {
		var err error
		if ns, err = strconv.ParseUint(namespace, 0, 64); err != nil {
			w.WriteHeader(http.StatusBadRequest)
			x.SetStatus(w, x.ErrorInvalidRequest, "Invalid namespace in query parameter.")
			return
		}
	}

	tablet := r.URL.Query().Get("tablet")
	if len(tablet) == 0 {
		w.WriteHeader(http.StatusBadRequest)
		x.SetStatus(w, x.ErrorInvalidRequest, "tablet is a mandatory query parameter")
		return
	}

	groupId, ok := intFromQueryParam(w, r, "group")
	if !ok {
		w.WriteHeader(http.StatusBadRequest)
		x.SetStatus(w, x.ErrorInvalidRequest,
			"Query parameter 'group' should contain a valid integer.")
		return
	}
	dstGroup := uint32(groupId)

	var resp *pb.Status
	var err error
	if resp, err = st.zero.MoveTablet(
		context.Background(),
		&pb.MoveTabletRequest{Namespace: ns, Tablet: tablet, DstGroup: dstGroup},
	); err != nil {
		if resp.GetMsg() == x.ErrorInvalidRequest {
			w.WriteHeader(http.StatusBadRequest)
			x.SetStatus(w, x.ErrorInvalidRequest, err.Error())
		} else {
			w.WriteHeader(http.StatusInternalServerError)
			x.SetStatus(w, x.Error, err.Error())