Method ServeHTTP

rest_backup_restore.go:419–456

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

}

func (h *BucketBackupIndexHandler) ServeHTTP(
	w http.ResponseWriter, req *http.Request) {
	bucketName := rest.BucketNameLookup(req)
	if bucketName == "" {
		rest.ShowError(w, req, "rest_backup_restore: bucket name is required",
			http.StatusBadRequest)
		return
	}

	queryParams := req.URL.Query()
	var include bool
	params := queryParams.Get("exclude")
	if params == "" {
		params = queryParams.Get("include")
		include = true
	}

	_, scopeFilters, colFilters := parseBackupFilters(params, bucketName)

	indexDefs, _, err := cbgt.CfgGetIndexDefs(h.mgr.Cfg())
	if err != nil {
		rest.ShowError(w, req, "could not retrieve index defs", http.StatusInternalServerError)
		return
	}

	// filter index definitions for the given buckets/scopes/collections.
	indexDefs = filterIndexDefinitions(indexDefs, nil,
		scopeFilters, colFilters, include, true)

	rv := struct {
		Status    string          `json:"status"`
		IndexDefs *cbgt.IndexDefs `json:"indexDefs"`
	}{
		Status:    "ok",
		IndexDefs: indexDefs,
	}
	rest.MustEncode(w, rv)
}

// parseBackupFilters parses the backup filters which would be
// a comma seperated list of filters like,