Struct SyncWorkflowInterceptorContext 

pub struct SyncWorkflowInterceptorContext { /* private fields */ }

Workflow execution context available to sync-only inbound interceptors.

Implementations

impl SyncWorkflowInterceptorContext

pub fn context_value<K>(&self) -> Option<Rc<<K as WorkflowContextKey>::Value>>

where K: WorkflowContextKey,

Return the value associated with key type K in the current workflow context scope.

pub fn with_context_value<K, R>( &self, value: <K as WorkflowContextKey>::Value, f: impl FnOnce() -> R, ) -> R

where K: WorkflowContextKey,

Run synchronous interceptor code with value installed for key type K.

This is intended for query and update-validator interceptor chains, which cannot await.

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 cancellation_token(&self) -> WorkflowCancellationToken

Return the workflow’s root cancellation token.

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 current workflow task is happening under replay.

pub fn is_replaying_history_events(&self) -> bool

Returns true if the current work is replaying history events.

pub fn payload_converter(&self) -> &PayloadConverter

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

Trait Implementations

impl Clone for SyncWorkflowInterceptorContext

fn clone(&self) -> SyncWorkflowInterceptorContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.