Method SearchRPC

grpc_client.go:244–290

(ctx context.Context, req *scatterRequest,
	pbReq *pb.SearchRequest)

}

func (g *GrpcClient) SearchRPC(ctx context.Context, req *scatterRequest,
	pbReq *pb.SearchRequest) (*bleve.SearchResult, error) {
	res, err := g.GrpcCli.Search(ctx, pbReq)
	if err != nil || res == nil {
		log.Errorf("grpc_client: search err: %v", err)
		return nil, err
	}

	searchResult := &bleve.SearchResult{
		Status: &bleve.SearchStatus{
			Errors: make(map[string]error)},
		Request: req.searchRequest,
	}

	var response *pb.StreamSearchResults
	for {
		response, err = res.Recv()
		if err == io.EOF {
			err = nil
			break
		}
		if err != nil {
			break
		}

		switch r := response.Contents.(type) {

		case *pb.StreamSearchResults_Hits:
			if sw, ok := g.sc.(streamHandler); ok {
				err = sw.write(r.Hits.Bytes, r.Hits.Offsets, int(r.Hits.Total))
				if err != nil {
					break
				}
			}

		case *pb.StreamSearchResults_SearchResult:
			if r.SearchResult != nil {
				err = UnmarshalJSON(r.SearchResult, &searchResult)
				if err != nil {
					return searchResult, err
				}
			}
		}
	}

	return searchResult, err
}

func (g *GrpcClient) Query(ctx context.Context,
	req *scatterRequest) (*bleve.SearchResult, error) {