(
&self,
collection: &str,
start: &NodeId,
depth: u8,
edge_filter: Option<&EdgeFilter>,
)
| 16 | |
| 17 | impl NativeClient { |
| 18 | pub(super) async fn graph_traverse_impl( |
| 19 | &self, |
| 20 | collection: &str, |
| 21 | start: &NodeId, |
| 22 | depth: u8, |
| 23 | edge_filter: Option<&EdgeFilter>, |
| 24 | ) -> NodeDbResult<SubGraph> { |
| 25 | let mut conn = self.pool.acquire().await?; |
| 26 | let resp = conn |
| 27 | .send( |
| 28 | OpCode::GraphHop, |
| 29 | TextFields { |
| 30 | collection: Some(collection.to_string()), |
| 31 | start_node: Some(start.as_str().to_string()), |
| 32 | depth: Some(depth as u32), |
| 33 | edge_label: edge_filter.and_then(|f| f.labels.first().cloned()), |
| 34 | ..Default::default() |
| 35 | }, |
| 36 | ) |
| 37 | .await?; |
| 38 | parse_subgraph_response(&resp) |
| 39 | } |
| 40 | |
| 41 | pub(super) async fn graph_insert_edge_impl( |
| 42 | &self, |
no test coverage detected