Method Search

grpc_server.go:91–306

(req *pb.SearchRequest,
	stream pb.SearchService_SearchServer)

}

func (s *SearchService) Search(req *pb.SearchRequest,
	stream pb.SearchService_SearchServer) (err error) {
	startTime := time.Now()
	if req == nil {
		return status.Error(codes.FailedPrecondition,
			"grpc_server: Search empty search request")
	}

	defer func() {
		updateRpcFocusStats(startTime, s.mgr, req, stream.Context(), err)
	}()

	err = verifyRPCAuth(stream.Context(), req.IndexName, req)
	if err != nil {
		return status.Errorf(codes.PermissionDenied,
			"grpc_server: Search err: %v", err)
	}

	queryCtlParams := cbgt.QueryCtlParams{
		Ctl: cbgt.QueryCtl{
			Timeout: cbgt.QUERY_CTL_DEFAULT_TIMEOUT_MS,
		},
	}

	if req.QueryCtlParams != nil {
		err = UnmarshalJSON(req.QueryCtlParams, &queryCtlParams)
		if err != nil {
			return status.Errorf(codes.InvalidArgument,
				"grpc_server: Search parsing queryCtlParams, err: %v", err)
		}
	}

	queryPIndexes := QueryPIndexes{}
	if req.QueryPIndexes != nil {
		err = UnmarshalJSON(req.QueryPIndexes, &queryPIndexes)
		if err != nil {
			return status.Errorf(codes.InvalidArgument,
				"grpc_server: Search parsing queryPIndexes, err: %v", err)
		}
	}

	var sr *SearchRequest
	err = UnmarshalJSON(req.Contents, &sr)
	if err != nil {
		return status.Errorf(codes.InvalidArgument,
			"grpc_server: Search parsing searchRequest, err: %v", err)
	}
	var searchRequest *bleve.SearchRequest
	searchRequest, err = sr.ConvertToBleveSearchRequest()
	if err != nil {
		return status.Errorf(codes.InvalidArgument,
			"grpc_server: Search processing searchRequest, err: %v", err)
	}

	// pre process the query if applicable
	var undecoratedQuery query.Query
	var coordinatingNode bool
	if strings.Compare(cbgt.CfgAppVersion, "7.0.0") >= 0 {