Struct WorkflowsService 

pub struct WorkflowsService { /* private fields */ }

Implementations

impl WorkflowsService

pub fn from_options(opts: &WorkflowsOptions) -> Self

pub async fn start(&self, name: &str, input: Value) -> WorkflowInstance

pub async fn get(&self, id: &str) -> Option<WorkflowInstance>

pub async fn complete_step( &self, id: &str, step: &str, result: Value, ) -> Result<WorkflowInstance, String>

Advance to the next step, persisting result. Survives process restart via the store.

pub async fn wait_for_approval( &self, id: &str, ) -> Result<WorkflowInstance, String>

Park the workflow until Self::approve.

pub async fn approve(&self, id: &str) -> Result<WorkflowInstance, String>

Trait Implementations

impl Injectable for WorkflowsService

fn construct(_registry: &ProviderRegistry) -> Arc<Self>

fn scope() -> ProviderScope

Provider scope used when the module registers this type.

fn on_module_init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn on_module_destroy<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn on_application_bootstrap<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn on_before_application_shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

NestJS beforeApplicationShutdown: fires before on_application_shutdown / on_module_destroy during graceful shutdown. Use to flush caches, close long-lived connections, or release resources while dependents are still alive.

fn on_application_shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,