Method dispatch_vector

nodedb/src/data/executor/dispatch/vector.rs:13–265

(&mut self, task: &ExecutionTask, op: &VectorOp)

impl CoreLoop {
    pub(super) fn dispatch_vector(&mut self, task: &ExecutionTask, op: &VectorOp) -> Response {
        let tid = task.request.tenant_id.as_u64();
        // Pressure guard for all write operations.
        let is_write = matches!(
            op,
            VectorOp::Insert { .. }
                | VectorOp::BatchInsert { .. }
                | VectorOp::SparseInsert { .. }
                | VectorOp::MultiVectorInsert { .. }
                | VectorOp::DirectUpsert { .. }
        );
        if is_write && let Some(r) = self.check_engine_pressure(task, nodedb_mem::EngineId::Vector)
        {
            return r;
        }
        match op {
            VectorOp::Insert {
                collection,
                vector,
                dim,
                field_name,
                surrogate,
            } => self.execute_vector_insert(super::super::handlers::vector::VectorInsertParams {
                task,
                tid,
                collection,
                vector,
                dim: *dim,
                field_name,
                surrogate: *surrogate,
            }),

            VectorOp::BatchInsert {
                collection,
                vectors,
                dim,
                surrogates,
            } => self.execute_vector_batch_insert(task, tid, collection, vectors, *dim, surrogates),

            VectorOp::MultiSearch {
                collection,
                query_vector,
                top_k,
                ef_search,
                filter_bitmap,
                rls_filters,
            } => self.execute_vector_multi_search(
                super::super::handlers::vector_search::VectorMultiSearchParams {
                    task,
                    tid,
                    collection,
                    query_vector,
                    top_k: *top_k,
                    ef_search: *ef_search,
                    filter_bitmap: filter_bitmap.as_ref(),
                    rls_filters,
                },
            ),