(
&self,
collection: &str,
query: &[f32],
k: usize,
filter: Option<&MetadataFilter>,
)
| 14 | |
| 15 | impl NativeClient { |
| 16 | pub(super) async fn vector_search_impl( |
| 17 | &self, |
| 18 | collection: &str, |
| 19 | query: &[f32], |
| 20 | k: usize, |
| 21 | filter: Option<&MetadataFilter>, |
| 22 | ) -> NodeDbResult<Vec<SearchResult>> { |
| 23 | let request = build_vector_search_request(collection, query, k, filter)?; |
| 24 | let mut conn = self.pool.acquire().await?; |
| 25 | let resp = conn.send(OpCode::VectorSearch, request).await?; |
| 26 | parse_search_results(&resp) |
| 27 | } |
| 28 | |
| 29 | pub(super) async fn vector_insert_impl( |
| 30 | &self, |
no test coverage detected