Struct WorkflowContext 

pub struct WorkflowContext { /* private fields */ }

Implementations

impl WorkflowContext

pub fn activity<T: Serialize>( &self, activity_type: impl Into<String>, args: T, ) -> ActivityCall

pub fn activity_on_queue<T, Q>( &self, activity_type: impl Into<String>, task_queue: Option<Q>, args: T, ) -> ActivityCall

where T: Serialize, Q: Into<String>,

pub fn wait_signal(&self, signal_name: impl Into<String>) -> SignalCall

pub fn sleep(&self, duration: Duration) -> TimerCall

Wait for server-backed durable time without blocking the worker executor.

Polling this future emits one start_timer command and yields. The server records the deadline, so neither worker nor server restarts reset the wait. Replay resolves the future only from a TimerScheduled and TimerFired pair at the same position in the shared durable-command stream, with matching sequence, timer identity, and delay. Sub-second durations round up because protocol deadlines use whole seconds.

let mut worker = Worker::new(client, "rust-workers");
worker.register_workflow("delayed-greeting", |ctx, _input| async move {
    ctx.sleep(Duration::from_secs(5)).await?;
    Ok(json!({"status": "timer fired"}))
});

pub fn start_timer(&self, duration: Duration) -> TimerCall

Alias for WorkflowContext::sleep for timer-oriented workflow code.

Trait Implementations

impl Clone for WorkflowContext

fn clone(&self) -> WorkflowContext

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WorkflowContext

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.