Struct MemGraphExecutor 

pub struct MemGraphExecutor<S: WriteSetApplicator> { /* private fields */ }

Implementations

impl<S: WriteSetApplicator> MemGraphExecutor<S>

pub fn new(store: Arc<GraphStore>, tx_mgr: Arc<TxManager<S>>) -> Self

pub fn register_dag_edge_types(&self, types: &[String])

pub fn edge_count( &self, source: NodeId, edge_type: &str, snapshot: SnapshotId, ) -> usize

Trait Implementations

impl<S: WriteSetApplicator> GraphExecutor for MemGraphExecutor<S>

fn bfs( &self, start: NodeId, edge_types: Option<&[EdgeType]>, direction: Direction, min_depth: u32, max_depth: u32, snapshot: SnapshotId, ) -> Result<TraversalResult>

fn neighbors( &self, node: NodeId, edge_types: Option<&[EdgeType]>, direction: Direction, snapshot: SnapshotId, ) -> Result<Vec<(NodeId, EdgeType, HashMap<String, Value>)>>

fn insert_edge( &self, tx: TxId, source: NodeId, target: NodeId, edge_type: EdgeType, properties: HashMap<String, Value>, ) -> Result<bool>

fn delete_edge( &self, tx: TxId, source: NodeId, target: NodeId, edge_type: &str, ) -> Result<()>