MCPcopy Create free account
hub / github.com/atomicdotdev/atomic / get_kg_node

Method get_kg_node

atomic-core/src/pristine/txn/read.rs:889–906  ·  view source on GitHub ↗
(&self, id: &str)

Source from the content-addressed store, hash-verified

887
888impl KgTxnT for ReadTxn {
889 fn get_kg_node(&self, id: &str) -> PristineResult<Option<KgNode>> {
890 let table = match self.txn.open_table(KG_NODES) {
891 Ok(t) => t,
892 Err(redb::TableError::TableDoesNotExist(_)) => return Ok(None),
893 Err(e) => return Err(PristineError::from(e)),
894 };
895 match table.get(id)? {
896 Some(value) => {
897 let node: KgNode = serde_json::from_slice(value.value()).map_err(|e| {
898 PristineError::Serialization {
899 message: e.to_string(),
900 }
901 })?;
902 Ok(Some(node))
903 }
904 None => Ok(None),
905 }
906 }
907
908 fn get_kg_edges_from(&self, node_id: &str) -> PristineResult<Vec<KgEdge>> {
909 let from_table = match self.txn.open_multimap_table(KG_EDGES_FROM) {

Calls 1

getMethod · 0.65