Function QueryAlias

pindex_alias.go:92–143

(mgr *cbgt.Manager, indexName, indexUUID string,
	req []byte, res io.Writer)

}

func QueryAlias(mgr *cbgt.Manager, indexName, indexUUID string,
	req []byte, res io.Writer) error {
	queryCtlParams := cbgt.QueryCtlParams{
		Ctl: cbgt.QueryCtl{
			Timeout: cbgt.QUERY_CTL_DEFAULT_TIMEOUT_MS,
		},
	}

	err := UnmarshalJSON(req, &queryCtlParams)
	if err != nil {
		return fmt.Errorf("alias: QueryAlias"+
			" parsing queryCtlParams, err: %v", err)
	}

	var sr *SearchRequest
	err = UnmarshalJSON(req, &sr)
	if err != nil {
		return fmt.Errorf("alias: QueryAlias"+
			" parsing searchRequest, err: %v", err)
	}
	searchRequest, err := sr.ConvertToBleveSearchRequest()
	if err != nil {
		return fmt.Errorf("alias: QueryAlias"+
			" parsing searchRequest, err: %v", err)
	}

	ctx, cancel, cancelCh := setupContextAndCancelCh(queryCtlParams, nil)
	// defer a call to cancel, this ensures that goroutine from
	// setupContextAndCancelCh always exits
	defer cancel()

	alias, multiCollIndex, err := bleveIndexAliasForUserIndexAlias(mgr,
		indexName, indexUUID, true,
		queryCtlParams.Ctl.Consistency, cancelCh, true,
		queryCtlParams.Ctl.PartitionSelection)
	if err != nil {
		return err
	}

	searchResponse, err := alias.SearchInContext(ctx, searchRequest)
	if err != nil {
		return err
	}
	// additional processing with multi-collection indexes.
	if multiCollIndex {
		processAliasResponse(searchResponse)
	}

	rest.MustEncode(res, searchResponse)

	return nil
}

func processAliasResponse(searchResponse *bleve.SearchResult) {
	if searchResponse != nil {