Method handlePostIndexInit

rest/admin_api.go:297–376

handleIndexInit allows async index initialization to be run or managed

()

// handleIndexInit allows async index initialization to be run or managed
func (h *handler) handlePostIndexInit() error {
	action := cmp.Or(h.getQuery("action"), "start")

	if action == "stop" {
		h.server.DatabaseInitManager.Cancel(h.db.Name, fmt.Sprintf("Initialization stopped by %s", h.rq.URL))
		if err := h.db.AsyncIndexInitManager.Stop(); err != nil {
			return err
		}
		b, err := h.db.AsyncIndexInitManager.GetStatus(h.ctx())
		if err != nil {
			return err
		}
		h.writeRawJSON(b)
		return nil
	}

	if action != "start" {
		return base.HTTPErrorf(http.StatusBadRequest, "action %q not supported... must be either 'start' or 'stop'", action)
	}

	var req PostIndexInitRequest
	if err := h.readJSONInto(&req); err != nil {
		return err
	}
	if err := req.Validate(); err != nil {
		return err
	}

	currentDbConfig := h.server.GetDatabaseConfig(h.db.Name)

	if h.db.UseViews() {
		return base.HTTPErrorf(http.StatusBadRequest, "_index_init is a GSI-only feature and is not supported when using views")
	}

	var newDbConfig DatabaseConfig
	if err := base.DeepCopyInefficient(&newDbConfig, currentDbConfig); err != nil {
		return err
	}
	newDbConfig.Index.NumPartitions = req.NumPartitions

	var statusMap = make(db.IndexStatusByCollection, len(newDbConfig.Scopes))
	for scope := range newDbConfig.Scopes {
		statusMap[scope] = make(map[string]db.CollectionIndexStatus)
	}
	// init _default scope because it's still possible that a named scope can still initialize metadata indexes in _default._default
	if _, ok := statusMap[base.DefaultScope]; !ok {
		statusMap[base.DefaultScope] = make(map[string]db.CollectionIndexStatus, 1)
	}
	var statusCallback CollectionCallbackFunc = func(dbName string, scName base.ScopeAndCollectionName, status db.CollectionIndexStatus) {
		statusMap[scName.ScopeName()][scName.CollectionName()] = status
		if err := h.db.AsyncIndexInitManager.UpdateStatusClusterAware(h.ctx()); err != nil {
			base.WarnfCtx(h.ctx(), "Unable to update async index job status on cluster : %v", err)
		}
	}

	useLegacySyncDocsIndex := h.db.UseLegacySyncDocsIndex()
	if req.SeparatePrincipalIndexes != nil {
		useLegacySyncDocsIndex = !(*req.SeparatePrincipalIndexes)