#[non_exhaustive]pub struct ActivityInfo {Show 16 fields
pub task_token: Vec<u8>,
pub workflow_type: String,
pub workflow_namespace: String,
pub workflow_execution: Option<WorkflowExecution>,
pub activity_id: String,
pub activity_type: String,
pub task_queue: String,
pub heartbeat_timeout: Option<Duration>,
pub scheduled_time: Option<SystemTime>,
pub started_time: Option<SystemTime>,
pub deadline: Option<SystemTime>,
pub attempt: u32,
pub current_attempt_scheduled_time: Option<SystemTime>,
pub retry_policy: Option<RetryPolicy>,
pub is_local: bool,
pub priority: Priority,
}Expand description
Various information about a specific activity attempt.
Fields (Non-exhaustive)§
This struct is marked as non-exhaustive
Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.task_token: Vec<u8>An opaque token representing a specific Activity task.
workflow_type: StringThe type of the workflow that invoked this activity.
workflow_namespace: StringThe namespace of the workflow that invoked this activity.
workflow_execution: Option<WorkflowExecution>The execution of the workflow that invoked this activity.
activity_id: StringThe ID of this activity.
activity_type: StringThe type of this activity.
task_queue: StringThe task queue of this activity.
heartbeat_timeout: Option<Duration>The interval within which this activity must heartbeat or be timed out.
scheduled_time: Option<SystemTime>Time activity was scheduled by a workflow.
started_time: Option<SystemTime>Time of activity start.
deadline: Option<SystemTime>Time of activity timeout.
attempt: u32Attempt starts from 1, and increase by 1 for every retry, if retry policy is specified.
current_attempt_scheduled_time: Option<SystemTime>Time this attempt at the activity was scheduled.
retry_policy: Option<RetryPolicy>The retry policy for this activity.
is_local: boolWhether or not this is a local activity.
priority: PriorityPriority of this activity. If unset uses Priority::default.
Trait Implementations§
Source§impl Clone for ActivityInfo
impl Clone for ActivityInfo
Source§fn clone(&self) -> ActivityInfo
fn clone(&self) -> ActivityInfo
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreAuto Trait Implementations§
impl Freeze for ActivityInfo
impl RefUnwindSafe for ActivityInfo
impl Send for ActivityInfo
impl Sync for ActivityInfo
impl Unpin for ActivityInfo
impl UnsafeUnpin for ActivityInfo
impl UnwindSafe for ActivityInfo
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
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>
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>
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>
T in a tonic::Request