(&mut self, task: &ExecutionTask, op: &TextOp)
| 10 | |
| 11 | impl CoreLoop { |
| 12 | pub(super) fn dispatch_text(&mut self, task: &ExecutionTask, op: &TextOp) -> Response { |
| 13 | let tid = task.request.tenant_id.as_u64(); |
| 14 | match op { |
| 15 | TextOp::Search { |
| 16 | collection, |
| 17 | query, |
| 18 | top_k, |
| 19 | fuzzy, |
| 20 | prefilter, |
| 21 | rls_filters, |
| 22 | } => self.execute_text_search( |
| 23 | task, |
| 24 | tid, |
| 25 | collection, |
| 26 | query, |
| 27 | *top_k, |
| 28 | *fuzzy, |
| 29 | prefilter.as_ref(), |
| 30 | rls_filters, |
| 31 | ), |
| 32 | |
| 33 | TextOp::BM25ScoreScan { |
| 34 | collection, |
| 35 | query, |
| 36 | score_alias, |
| 37 | fuzzy, |
| 38 | } => self.execute_bm25_score_scan(task, tid, collection, query, score_alias, *fuzzy), |
| 39 | |
| 40 | TextOp::PhraseSearch { |
| 41 | collection, |
| 42 | terms, |
| 43 | top_k, |
| 44 | prefilter, |
| 45 | } => { |
| 46 | self.execute_phrase_search(task, tid, collection, terms, *top_k, prefilter.as_ref()) |
| 47 | } |
| 48 | |
| 49 | TextOp::HybridSearch { |
| 50 | collection, |
| 51 | query_vector, |
| 52 | query_text, |
| 53 | top_k, |
| 54 | ef_search, |
| 55 | fuzzy, |
| 56 | vector_weight, |
| 57 | filter_bitmap, |
| 58 | rls_filters, |
| 59 | score_alias, |
| 60 | } => self.execute_hybrid_search( |
| 61 | task, |
| 62 | tid, |
| 63 | collection, |
| 64 | query_vector, |
| 65 | query_text, |
| 66 | *top_k, |
| 67 | *ef_search, |
| 68 | *fuzzy, |
| 69 | *vector_weight, |
no test coverage detected