Skip to main content

WorkflowContextView

Struct WorkflowContextView 

Source
#[non_exhaustive]
pub struct WorkflowContextView { /* private fields */ }
Expand description

Read-only view of workflow context for use in init, query, and update-validator handlers.

This provides access to workflow information but cannot issue commands.

Implementations§

Source§

impl WorkflowContextView

Source

pub fn workflow_id(&self) -> &str

Returns the workflow’s unique identifier.

Source

pub fn run_id(&self) -> &str

Returns the run ID of this workflow execution.

Source

pub fn workflow_type(&self) -> &str

Returns the workflow type name.

Source

pub fn task_queue(&self) -> &str

Returns the task queue this workflow is executing on.

Source

pub fn namespace(&self) -> &str

Returns the namespace this workflow is executing in.

Source

pub fn attempt(&self) -> u32

Returns the current attempt number, starting from one.

Source

pub fn first_execution_run_id(&self) -> &str

Returns the run ID of the first execution in the chain.

Source

pub fn continued_from_run_id(&self) -> Option<&str>

Returns the run ID of the previous execution when this is a continuation.

Source

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

Returns when the workflow execution started.

Source

pub fn execution_timeout(&self) -> Option<Duration>

Returns the total workflow execution timeout, including retries and continue-as-new.

Source

pub fn run_timeout(&self) -> Option<Duration>

Returns the timeout of a single workflow run.

Source

pub fn task_timeout(&self) -> Option<Duration>

Returns the timeout of a single workflow task.

Source

pub fn parent(&self) -> Option<NamespacedWorkflowInfo>

Returns information about the parent workflow when this is a child workflow.

Source

pub fn root(&self) -> Option<WorkflowExecution>

Returns information about the root workflow in the execution chain.

Source

pub fn retry_policy(&self) -> Option<RetryPolicy>

Returns the workflow’s retry policy.

Source

pub fn cron_schedule(&self) -> Option<&str>

Returns the cron schedule when this workflow runs on one.

Source

pub fn priority(&self) -> Priority

Returns priority and fairness configuration for this workflow execution.

Source

pub fn memo(&self) -> Memo

Returns user-defined memo values.

Source

pub fn search_attributes(&self) -> Option<SearchAttributes>

Returns initial search attributes as a typed collection.

Source

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

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

This allows queries and update validators to observe values established by synchronous inbound interceptors without allowing the handler to modify the context scope.

Source

pub fn raw(&self) -> &InitializeWorkflow

Accesses the underlying workflow initialization protobuf.

Source

pub fn into_raw(self) -> InitializeWorkflow

Consumes this view and returns the underlying workflow initialization protobuf.

Trait Implementations§

Source§

impl Clone for WorkflowContextView

Source§

fn clone(&self) -> WorkflowContextView

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for WorkflowContextView

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Any for T
where T: Any,

Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Source§

fn into_any_rc(self: Rc<T>) -> Rc<dyn Any>

Source§

fn type_name(&self) -> &'static str

Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DynClone for T
where T: Clone,

Source§

fn __clone_box(&self, _: Private) -> *mut ()

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> IntoRequest<T> for T

Source§

fn into_request(self) -> Request<T>

Wrap the input message T in a tonic::Request
Source§

impl<L> LayerExt<L> for L

Source§

fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>
where L: Layer<S>,

Applies the layer to a service and wraps it in Layered.
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = !

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, !>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

impl<T> WorkflowOutboundValue for T
where T: Any,

Source§

fn as_any(&self) -> &(dyn Any + 'static)

Access the concrete value through Any.
Source§

fn into_any(self: Box<T>) -> Box<dyn Any>

Convert this value into Any for a consuming downcast.