(ctx context.Context, in *pb.Query, idx int, or chan orderResult)
| 580 | } |
| 581 | |
| 582 | func fetchValues(ctx context.Context, in *pb.Query, idx int, or chan orderResult) { |
| 583 | var err error |
| 584 | in.Reverse = strings.HasPrefix(in.Attr, "~") |
| 585 | if in.Reverse { |
| 586 | in.Attr = strings.TrimPrefix(in.Attr, "~") |
| 587 | } |
| 588 | r, err := ProcessTaskOverNetwork(ctx, in) |
| 589 | or <- orderResult{ |
| 590 | idx: idx, |
| 591 | err: err, |
| 592 | r: r, |
| 593 | } |
| 594 | } |
| 595 | |
| 596 | type intersectedList struct { |
| 597 | offset int |
no test coverage detected