Method SearchInContext

remote.go:184–266

(ctx context.Context,
	req *bleve.SearchRequest)

}

func (r *IndexClient) SearchInContext(ctx context.Context,
	req *bleve.SearchRequest) (*bleve.SearchResult, error) {
	if req == nil {
		return nil, fmt.Errorf("remote: no req provided")
	}

	if r.QueryURL == "" {
		return nil, fmt.Errorf("remote: no QueryURL provided")
	}

	queryCtlParams := &cbgt.QueryCtlParams{
		Ctl: cbgt.QueryCtl{
			Consistency: r.Consistency,
		},
	}

	queryPIndexes := &QueryPIndexes{
		PIndexNames: r.PIndexNames,
	}

	// if timeout was set, compute time remaining
	if deadline, ok := ctx.Deadline(); ok {
		remaining := deadline.Sub(time.Now())
		// FIXME arbitrarily reducing the timeout, to increase the liklihood
		// that a live system replies via HTTP round-trip before we give up
		// on the request externally
		remaining -= RemoteRequestOverhead
		if remaining <= 0 {
			// not enough time left
			return nil, context.DeadlineExceeded
		}
		queryCtlParams.Ctl.Timeout = int64(remaining / time.Millisecond)
	}

	buf, err := MarshalJSON(struct {
		*cbgt.QueryCtlParams
		*QueryPIndexes
		*bleve.SearchRequest
	}{
		queryCtlParams,
		queryPIndexes,
		req,
	})
	if err != nil {
		return nil, err
	}

	resultCh := make(chan *bleve.SearchResult, 1)

	go func() {
		respBuf, err := r.Query(buf)
		if err != nil {
			log.Warnf("remote: Query() returned error from host: %v,"+
				" err: %v", r.HostPort, err)
			resultCh <- makeSearchResultErr(req, r.PIndexNames, err)
			return
		}