pub struct PregelExecutor<'a> { /* private fields */ }Available on crate feature
graph only.Expand description
Pregel-based executor for graphs
Implementations§
Source§impl<'a> PregelExecutor<'a>
impl<'a> PregelExecutor<'a>
Sourcepub fn new(
graph: &'a CompiledGraph,
config: ExecutionConfig,
) -> PregelExecutor<'a>
pub fn new( graph: &'a CompiledGraph, config: ExecutionConfig, ) -> PregelExecutor<'a>
Create a new executor
Sourcepub async fn run(
&mut self,
input: HashMap<String, Value>,
) -> Result<HashMap<String, Value>, GraphError>
pub async fn run( &mut self, input: HashMap<String, Value>, ) -> Result<HashMap<String, Value>, GraphError>
Run the graph to completion
Sourcepub fn run_stream(
self,
input: HashMap<String, Value>,
mode: StreamMode,
) -> impl Stream<Item = Result<StreamEvent, GraphError>> + 'a
pub fn run_stream( self, input: HashMap<String, Value>, mode: StreamMode, ) -> impl Stream<Item = Result<StreamEvent, GraphError>> + 'a
Run with streaming
Auto Trait Implementations§
impl<'a> Freeze for PregelExecutor<'a>
impl<'a> !RefUnwindSafe for PregelExecutor<'a>
impl<'a> Send for PregelExecutor<'a>
impl<'a> Sync for PregelExecutor<'a>
impl<'a> Unpin for PregelExecutor<'a>
impl<'a> UnsafeUnpin for PregelExecutor<'a>
impl<'a> !UnwindSafe for PregelExecutor<'a>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more