Struct WorkflowManager 

pub struct WorkflowManager { /* private fields */ }

Client for starting workflow runs and managing schedules or triggers.

Implementations

impl WorkflowManager

pub async fn connect( invocation_token: impl AsRef<str>, ) -> Result<Self, WorkflowManagerError>

Connects to the workflow manager with an invocation token from the host.

pub async fn connect_with_idempotency_key( invocation_token: impl AsRef<str>, idempotency_key: impl AsRef<str>, ) -> Result<Self, WorkflowManagerError>

Connects with a default idempotency key for create requests.

pub async fn create_schedule( &mut self, request: WorkflowManagerCreateScheduleRequest, ) -> Result<ManagedWorkflowSchedule, WorkflowManagerError>

Creates a workflow schedule.

pub async fn start_run( &mut self, request: WorkflowManagerStartRunRequest, ) -> Result<ManagedWorkflowRun, WorkflowManagerError>

Starts a workflow run.

pub async fn signal_run( &mut self, request: WorkflowManagerSignalRunRequest, ) -> Result<ManagedWorkflowRunSignal, WorkflowManagerError>

Signals an existing workflow run.

pub async fn signal_or_start_run( &mut self, request: WorkflowManagerSignalOrStartRunRequest, ) -> Result<ManagedWorkflowRunSignal, WorkflowManagerError>

Signals a run or starts it when no matching run exists.

pub async fn get_schedule( &mut self, request: WorkflowManagerGetScheduleRequest, ) -> Result<ManagedWorkflowSchedule, WorkflowManagerError>

Fetches one workflow schedule.

pub async fn update_schedule( &mut self, request: WorkflowManagerUpdateScheduleRequest, ) -> Result<ManagedWorkflowSchedule, WorkflowManagerError>

Updates a workflow schedule.

pub async fn delete_schedule( &mut self, request: WorkflowManagerDeleteScheduleRequest, ) -> Result<(), WorkflowManagerError>

Deletes a workflow schedule.

pub async fn pause_schedule( &mut self, request: WorkflowManagerPauseScheduleRequest, ) -> Result<ManagedWorkflowSchedule, WorkflowManagerError>

Pauses a workflow schedule.

pub async fn resume_schedule( &mut self, request: WorkflowManagerResumeScheduleRequest, ) -> Result<ManagedWorkflowSchedule, WorkflowManagerError>

Resumes a workflow schedule.

pub async fn create_trigger( &mut self, request: WorkflowManagerCreateEventTriggerRequest, ) -> Result<ManagedWorkflowEventTrigger, WorkflowManagerError>

Creates an event trigger.

pub async fn get_trigger( &mut self, request: WorkflowManagerGetEventTriggerRequest, ) -> Result<ManagedWorkflowEventTrigger, WorkflowManagerError>

Fetches one event trigger.

pub async fn update_trigger( &mut self, request: WorkflowManagerUpdateEventTriggerRequest, ) -> Result<ManagedWorkflowEventTrigger, WorkflowManagerError>

Updates an event trigger.

pub async fn delete_trigger( &mut self, request: WorkflowManagerDeleteEventTriggerRequest, ) -> Result<(), WorkflowManagerError>

Deletes an event trigger.

pub async fn pause_trigger( &mut self, request: WorkflowManagerPauseEventTriggerRequest, ) -> Result<ManagedWorkflowEventTrigger, WorkflowManagerError>

Pauses an event trigger.

pub async fn resume_trigger( &mut self, request: WorkflowManagerResumeEventTriggerRequest, ) -> Result<ManagedWorkflowEventTrigger, WorkflowManagerError>

Resumes an event trigger.

pub async fn publish_event( &mut self, request: WorkflowManagerPublishEventRequest, ) -> Result<WorkflowEvent, WorkflowManagerError>

Publishes an event into the workflow manager.