pub struct ActivityContext { /* private fields */ }Expand description
Used within activities to get info, heartbeat management etc.
Implementations§
Source§impl ActivityContext
impl ActivityContext
Sourcepub async fn cancelled(&self)
pub async fn cancelled(&self)
Returns a future the completes if and when the activity this was called inside has been cancelled
Sourcepub fn is_cancelled(&self) -> bool
pub fn is_cancelled(&self) -> bool
Returns true if this activity has already been cancelled
Sourcepub fn heartbeat_details(&self) -> &ActivityHeartbeatDetails
pub fn heartbeat_details(&self) -> &ActivityHeartbeatDetails
Extract heartbeat details from last failed attempt. This is used in combination with retry policy.
Sourcepub async fn record_heartbeat<T>(
&self,
details: T,
) -> Result<(), PayloadConversionError>where
T: TemporalSerializable + 'static,
pub async fn record_heartbeat<T>(
&self,
details: T,
) -> Result<(), PayloadConversionError>where
T: TemporalSerializable + 'static,
Record a heartbeat with typed progress details for the currently executing activity.
Sourcepub fn info(&self) -> &ActivityInfo
pub fn info(&self) -> &ActivityInfo
Returns activity info of the executing activity
Sourcepub fn client(&self) -> Client
pub fn client(&self) -> Client
Return a client targeting the same Temporal service and namespace as this activity’s worker.
Sourcepub fn workflow_handle<W: HasWorkflowDefinition>(
&self,
) -> Option<WorkflowHandle<Client, W>>
pub fn workflow_handle<W: HasWorkflowDefinition>( &self, ) -> Option<WorkflowHandle<Client, W>>
Return a workflow handle for the workflow execution that started this activity, if any.
Trait Implementations§
Source§impl Clone for ActivityContext
impl Clone for ActivityContext
Source§fn clone(&self) -> ActivityContext
fn clone(&self) -> ActivityContext
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 ActivityContext
impl !UnwindSafe for ActivityContext
impl Freeze for ActivityContext
impl Send for ActivityContext
impl Sync for ActivityContext
impl Unpin for ActivityContext
impl UnsafeUnpin for ActivityContext
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> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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 moreSource§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