pub struct DefaultWorkflowApi { /* private fields */ }Expand description
Default API implementation
Implementations§
Source§impl DefaultWorkflowApi
impl DefaultWorkflowApi
pub fn new(engine: Arc<dyn WorkflowEngine>) -> Self
Trait Implementations§
Source§impl WorkflowApi for DefaultWorkflowApi
impl WorkflowApi for DefaultWorkflowApi
fn create_workflow<'life0, 'async_trait>(
&'life0 self,
req: CreateWorkflowRequest,
) -> Pin<Box<dyn Future<Output = WorkflowResult<WorkflowState>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn get_workflow<'life0, 'life1, 'async_trait>(
&'life0 self,
workflow_id: &'life1 str,
) -> Pin<Box<dyn Future<Output = WorkflowResult<WorkflowState>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn get_tasks<'life0, 'life1, 'async_trait>(
&'life0 self,
workflow_id: &'life1 str,
) -> Pin<Box<dyn Future<Output = WorkflowResult<Vec<TaskState>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn complete_task<'life0, 'life1, 'async_trait>(
&'life0 self,
task_id: &'life1 str,
req: CompleteTaskRequest,
) -> Pin<Box<dyn Future<Output = WorkflowResult<TaskState>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Auto Trait Implementations§
impl Freeze for DefaultWorkflowApi
impl !RefUnwindSafe for DefaultWorkflowApi
impl Send for DefaultWorkflowApi
impl Sync for DefaultWorkflowApi
impl Unpin for DefaultWorkflowApi
impl UnsafeUnpin for DefaultWorkflowApi
impl !UnwindSafe for DefaultWorkflowApi
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
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more