pub struct ActivityContext { /* private fields */ }Expand description
Used within activities to get info, heartbeat management etc.
Implementations§
Source§impl ActivityContext
impl ActivityContext
Sourcepub fn new(
worker: Arc<CoreWorker>,
cancellation_token: CancellationToken,
task_queue: String,
task_token: Vec<u8>,
task: Start,
) -> (Self, Vec<Payload>)
pub fn new( worker: Arc<CoreWorker>, cancellation_token: CancellationToken, task_queue: String, task_token: Vec<u8>, task: Start, ) -> (Self, Vec<Payload>)
Construct new Activity Context, returning the context and all arguments to the activity.
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) -> &[Payload]
pub fn heartbeat_details(&self) -> &[Payload]
Extract heartbeat details from last failed attempt. This is used in combination with retry policy.
Sourcepub fn record_heartbeat(&self, details: Vec<Payload>)
pub fn record_heartbeat(&self, details: Vec<Payload>)
RecordHeartbeat sends heartbeat for the currently executing activity
Sourcepub fn info(&self) -> &ActivityInfo
pub fn info(&self) -> &ActivityInfo
Returns activity info of the executing activity
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 · 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 Freeze for ActivityContext
impl !RefUnwindSafe for ActivityContext
impl Send for ActivityContext
impl Sync for ActivityContext
impl Unpin for ActivityContext
impl UnsafeUnpin for ActivityContext
impl !UnwindSafe 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> FutureExt for T
impl<T> FutureExt for T
Source§fn with_context(self, otel_cx: Context) -> WithContext<Self>
fn with_context(self, otel_cx: Context) -> WithContext<Self>
Source§fn with_current_context(self) -> WithContext<Self>
fn with_current_context(self) -> WithContext<Self>
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