pub struct BaseWorkflowContext { /* private fields */ }Expand description
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§
Source§impl BaseWorkflowContext
impl BaseWorkflowContext
Sourcepub fn data_converter(&self) -> &DataConverter
pub fn data_converter(&self) -> &DataConverter
Returns the DataConverter associated with this workflow’s worker.
Source§impl BaseWorkflowContext
impl BaseWorkflowContext
Sourcepub fn current_details(&self) -> String
pub fn current_details(&self) -> String
Return the current value of current_details.
Sourcepub fn timer<T: Into<TimerOptions>>(
&self,
opts: T,
) -> impl CancellableFuture<TimerResult> + use<T>
pub fn timer<T: Into<TimerOptions>>( &self, opts: T, ) -> impl CancellableFuture<TimerResult> + use<T>
Request to create a timer
Sourcepub fn start_activity<AD: ActivityDefinition>(
&self,
_activity: AD,
input: impl Into<AD::Input>,
opts: ActivityOptions,
) -> impl CancellableFuture<Result<AD::Output, ActivityExecutionError>>where
AD::Output: TemporalDeserializable,
pub fn start_activity<AD: ActivityDefinition>(
&self,
_activity: AD,
input: impl Into<AD::Input>,
opts: ActivityOptions,
) -> impl CancellableFuture<Result<AD::Output, ActivityExecutionError>>where
AD::Output: TemporalDeserializable,
Request to run an activity
Sourcepub fn start_local_activity<AD: ActivityDefinition>(
&self,
_activity: AD,
input: impl Into<AD::Input>,
opts: LocalActivityOptions,
) -> impl CancellableFuture<Result<AD::Output, ActivityExecutionError>>where
AD::Output: TemporalDeserializable,
pub fn start_local_activity<AD: ActivityDefinition>(
&self,
_activity: AD,
input: impl Into<AD::Input>,
opts: LocalActivityOptions,
) -> impl CancellableFuture<Result<AD::Output, ActivityExecutionError>>where
AD::Output: TemporalDeserializable,
Request to run a local activity
Trait Implementations§
Source§impl Clone for BaseWorkflowContext
impl Clone for BaseWorkflowContext
Source§fn clone(&self) -> BaseWorkflowContext
fn clone(&self) -> BaseWorkflowContext
Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreAuto Trait Implementations§
impl !RefUnwindSafe for BaseWorkflowContext
impl !Send for BaseWorkflowContext
impl !Sync for BaseWorkflowContext
impl !UnwindSafe for BaseWorkflowContext
impl Freeze for BaseWorkflowContext
impl Unpin for BaseWorkflowContext
impl UnsafeUnpin for BaseWorkflowContext
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request