pub struct RespondActivityTaskFailedRequest {
pub task_token: Vec<u8>,
pub failure: Option<Failure>,
pub identity: String,
pub namespace: String,
pub resource_id: String,
pub last_heartbeat_details: Option<Payloads>,
pub worker_version: Option<WorkerVersionStamp>,
pub deployment: Option<Deployment>,
pub deployment_options: Option<WorkerDeploymentOptions>,
}Fields§
§task_token: Vec<u8>The task token as received in PollActivityTaskQueueResponse
failure: Option<Failure>Detailed failure information
identity: StringThe identity of the worker/client
namespace: String§resource_id: StringResource ID for routing. Contains the workflow ID or activity ID for standalone activities.
last_heartbeat_details: Option<Payloads>Additional details to be stored as last activity heartbeat
worker_version: Option<WorkerVersionStamp>Version info of the worker who processed this task. This message’s build_id field should
always be set by SDKs. Workers opting into versioning will also set the use_versioning
field to true. See message docstrings for more.
Deprecated. Use deployment_options instead.
deployment: Option<Deployment>Deployment info of the worker that completed this task. Must be present if user has set
WorkerDeploymentOptions regardless of versioning being enabled or not.
Deprecated. Replaced with deployment_options.
deployment_options: Option<WorkerDeploymentOptions>Worker deployment options that user has set in the worker.
Trait Implementations§
Source§impl Clone for RespondActivityTaskFailedRequest
impl Clone for RespondActivityTaskFailedRequest
Source§fn clone(&self) -> RespondActivityTaskFailedRequest
fn clone(&self) -> RespondActivityTaskFailedRequest
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Message for RespondActivityTaskFailedRequest
impl Message for RespondActivityTaskFailedRequest
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self.Source§impl Name for RespondActivityTaskFailedRequest
impl Name for RespondActivityTaskFailedRequest
Source§const NAME: &'static str = "RespondActivityTaskFailedRequest"
const NAME: &'static str = "RespondActivityTaskFailedRequest"
Message.
This name is the same as it appears in the source .proto file, e.g. FooBar.Source§const PACKAGE: &'static str = "temporal.api.workflowservice.v1"
const PACKAGE: &'static str = "temporal.api.workflowservice.v1"
., e.g. google.protobuf.Source§fn full_name() -> String
fn full_name() -> String
Message.
It’s prefixed with the package name and names of any parent messages,
e.g. google.rpc.BadRequest.FieldViolation.
By default, this is the package name followed by the message name.
Fully-qualified names must be unique within a domain of Type URLs.Source§impl PartialEq for RespondActivityTaskFailedRequest
impl PartialEq for RespondActivityTaskFailedRequest
Source§fn eq(&self, other: &RespondActivityTaskFailedRequest) -> bool
fn eq(&self, other: &RespondActivityTaskFailedRequest) -> bool
self and other values to be equal, and is used by ==.§impl PayloadVisitable for RespondActivityTaskFailedRequest
impl PayloadVisitable for RespondActivityTaskFailedRequest
§fn visit_payloads_mut<'a>(
&'a mut self,
visitor: &'a mut (dyn AsyncPayloadVisitor + Send),
) -> BoxFuture<'a, ()>
fn visit_payloads_mut<'a>( &'a mut self, visitor: &'a mut (dyn AsyncPayloadVisitor + Send), ) -> BoxFuture<'a, ()>
impl StructuralPartialEq for RespondActivityTaskFailedRequest
Auto Trait Implementations§
impl Freeze for RespondActivityTaskFailedRequest
impl RefUnwindSafe for RespondActivityTaskFailedRequest
impl Send for RespondActivityTaskFailedRequest
impl Sync for RespondActivityTaskFailedRequest
impl Unpin for RespondActivityTaskFailedRequest
impl UnsafeUnpin for RespondActivityTaskFailedRequest
impl UnwindSafe for RespondActivityTaskFailedRequest
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> 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>
T in a tonic::Request