| 76 | } |
| 77 | |
| 78 | pub(super) async fn graph_delete_edge_impl( |
| 79 | &self, |
| 80 | collection: &str, |
| 81 | edge_id: &EdgeId, |
| 82 | ) -> NodeDbResult<()> { |
| 83 | let mut conn = self.pool.acquire().await?; |
| 84 | conn.send( |
| 85 | OpCode::EdgeDelete, |
| 86 | TextFields { |
| 87 | collection: Some(collection.to_string()), |
| 88 | from_node: Some(edge_id.src.as_str().to_string()), |
| 89 | to_node: Some(edge_id.dst.as_str().to_string()), |
| 90 | edge_type: Some(edge_id.label.clone()), |
| 91 | ..Default::default() |
| 92 | }, |
| 93 | ) |
| 94 | .await?; |
| 95 | Ok(()) |
| 96 | } |
| 97 | |
| 98 | pub(super) async fn graph_stats_impl( |
| 99 | &self, |