pub enum PendingActivityReport {
Completed {
workflow_id: WorkflowId,
activity_id: ActivityId,
output: Payload,
},
Failed {
workflow_id: WorkflowId,
activity_id: ActivityId,
failure: ActivityError,
},
}Expand description
Result or failure computed locally and not yet acknowledged by the engine.
Variants§
Completed
Successful activity output to re-report until acknowledged.
Fields
§
workflow_id: WorkflowIdWorkflow owning the activity.
§
activity_id: ActivityIdActivity identifier used by AW for idempotent ingest.
Failed
Explicitly classified activity failure to re-report until acknowledged.
Fields
§
workflow_id: WorkflowIdWorkflow owning the activity.
§
activity_id: ActivityIdActivity identifier used by AW for idempotent ingest.
§
failure: ActivityErrorClassified activity error.
Implementations§
Source§impl PendingActivityReport
impl PendingActivityReport
Sourcepub const fn activity_id(&self) -> &ActivityId
pub const fn activity_id(&self) -> &ActivityId
Returns the report’s activity id key.
Sourcepub const fn workflow_id(&self) -> &WorkflowId
pub const fn workflow_id(&self) -> &WorkflowId
Returns the workflow owning the report’s activity.
Trait Implementations§
Source§impl Clone for PendingActivityReport
impl Clone for PendingActivityReport
Source§fn clone(&self) -> PendingActivityReport
fn clone(&self) -> PendingActivityReport
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 moreSource§impl Debug for PendingActivityReport
impl Debug for PendingActivityReport
impl Eq for PendingActivityReport
Source§impl PartialEq for PendingActivityReport
impl PartialEq for PendingActivityReport
Source§fn eq(&self, other: &PendingActivityReport) -> bool
fn eq(&self, other: &PendingActivityReport) -> bool
Tests for
self and other values to be equal, and is used by ==.impl StructuralPartialEq for PendingActivityReport
Auto Trait Implementations§
impl Freeze for PendingActivityReport
impl RefUnwindSafe for PendingActivityReport
impl Send for PendingActivityReport
impl Sync for PendingActivityReport
impl Unpin for PendingActivityReport
impl UnsafeUnpin for PendingActivityReport
impl UnwindSafe for PendingActivityReport
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<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key and return true if they are equal.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