Method dispatch_kv

nodedb/src/data/executor/dispatch/kv.rs:12–34

(&mut self, task: &ExecutionTask, tid: u64, op: &KvOp)

impl CoreLoop {
    pub(super) fn dispatch_kv(&mut self, task: &ExecutionTask, tid: u64, op: &KvOp) -> Response {
        let is_kv_write = matches!(
            op,
            KvOp::Put { .. }
                | KvOp::Insert { .. }
                | KvOp::InsertIfAbsent { .. }
                | KvOp::InsertOnConflictUpdate { .. }
                | KvOp::Delete { .. }
                | KvOp::BatchPut { .. }
                | KvOp::Expire { .. }
                | KvOp::FieldSet { .. }
                | KvOp::Incr { .. }
                | KvOp::IncrFloat { .. }
                | KvOp::Cas { .. }
                | KvOp::GetSet { .. }
                | KvOp::Transfer { .. }
                | KvOp::TransferItem { .. }
        );
        if is_kv_write && let Some(r) = self.check_engine_pressure(task, nodedb_mem::EngineId::Kv) {
            return r;
        }
        self.execute_kv(task, tid, op)
    }
}