Method execute_kv_batch_put

nodedb/src/data/executor/handlers/kv/batch.rs:46–71

(
        &mut self,
        task: &ExecutionTask,
        tid: u64,
        collection: &str,
        entries: &[(Vec<u8>, Vec<u8>)],
        ttl_ms: u64,
    )

    }

    pub(in crate::data::executor) fn execute_kv_batch_put(
        &mut self,
        task: &ExecutionTask,
        tid: u64,
        collection: &str,
        entries: &[(Vec<u8>, Vec<u8>)],
        ttl_ms: u64,
    ) -> Response {
        debug!(core = self.core_id, %collection, count = entries.len(), "kv batch put");
        let now_ms: u64 = self
            .epoch_system_ms
            .map(|ms| ms as u64)
            .unwrap_or_else(current_ms);
        let new_count = self
            .kv_engine
            .batch_put(tid, collection, entries, ttl_ms, now_ms);
        match response_codec::encode_count("inserted", new_count) {
            Ok(payload) => self.response_with_payload(task, payload),
            Err(e) => self.response_error(
                task,
                ErrorCode::Internal {
                    detail: e.to_string(),
                },
            ),
        }
    }
}