(
&self,
timestamp: EventTime,
src: GID,
dst: GID,
properties: Option<HashMap<String, Prop>>,
layer: Option<&str>,
)
| 329 | /// RemoteEdge: the remote edge |
| 330 | #[pyo3(signature = (timestamp, src, dst, properties = None, layer = None))] |
| 331 | pub fn add_edge( |
| 332 | &self, |
| 333 | timestamp: EventTime, |
| 334 | src: GID, |
| 335 | dst: GID, |
| 336 | properties: Option<HashMap<String, Prop>>, |
| 337 | layer: Option<&str>, |
| 338 | ) -> Result<PyRemoteEdge, ClientError> { |
| 339 | let graph = Arc::clone(&self.graph); |
| 340 | let layer = layer.map(|s| s.to_string()); |
| 341 | |
| 342 | let edge = execute_async_task(move || async move { |
| 343 | graph.add_edge(timestamp, src, dst, properties, layer).await |
| 344 | })?; |
| 345 | |
| 346 | Ok(PyRemoteEdge::new(edge)) |
| 347 | } |
| 348 | |
| 349 | /// Deletes an edge in the remote graph, given the timestamp, src and dst nodes and layer (optional) |
| 350 | /// |
nothing calls this directly
no test coverage detected