Struct BaseWorkflowContext 

pub struct BaseWorkflowContext { /* private fields */ }

Non-generic base context containing all workflow execution infrastructure.

This is used internally by futures and commands that don’t need typed workflow state.

Implementations

impl BaseWorkflowContext

pub fn data_converter(&self) -> &DataConverter

Returns the DataConverter associated with this workflow’s worker.

pub fn workflow_id(&self) -> &str

Return the workflow’s unique identifier.

pub fn run_id(&self) -> &str

Return the run id of this workflow execution.

pub fn namespace(&self) -> &str

Return the namespace the workflow is executing in.

pub fn task_queue(&self) -> &str

Return the task queue the workflow is executing in.

pub fn workflow_type(&self) -> &str

Return the workflow type name.

pub fn workflow_time(&self) -> Option<SystemTime>

Return the current time according to the workflow.

pub fn history_length(&self) -> u32

Return the length of history so far at this point in the workflow.

pub fn search_attributes(&self) -> SearchAttributes

Return current values for workflow search attributes.

pub fn is_replaying(&self) -> bool

Returns true if the workflow is replaying (including during queries and update validators), false otherwise.

pub fn is_replaying_history_events(&self) -> bool

Return true if the workflow is replaying history events (excluding queries and update validators), false otherwise.

pub fn payload_converter(&self) -> &PayloadConverter

Returns the payload converter used by the worker running this workflow.

impl BaseWorkflowContext

pub fn current_details(&self) -> String

Return the current value of current_details.

pub fn timer<T>(&self, opts: T) -> impl CancellableFuture<TimerResult> + use<T>

where T: Into<TimerOptions>,

Request to create a timer

pub fn execute_activity<AD>( &self, activity: AD, input: impl Into<<AD as ActivityDefinition>::Input>, opts: ActivityOptions, ) -> impl CancellableFuture<Result<<AD as ActivityDefinition>::Output, ActivityExecutionError>>

where AD: ActivityDefinition, <AD as ActivityDefinition>::Output: TemporalDeserializable,

Request to run an activity

pub fn execute_local_activity<AD>( &self, activity: AD, input: impl Into<<AD as ActivityDefinition>::Input>, opts: LocalActivityOptions, ) -> impl CancellableFuture<Result<<AD as ActivityDefinition>::Output, ActivityExecutionError>>

where AD: ActivityDefinition, <AD as ActivityDefinition>::Output: TemporalDeserializable,

Request to run a local activity

Trait Implementations

impl Clone for BaseWorkflowContext

fn clone(&self) -> BaseWorkflowContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.