Struct temporal_sdk_core::protos::temporal::api::workflowservice::v1::PollActivityTaskQueueResponse [−][src]
pub struct PollActivityTaskQueueResponse {}Show fields
pub task_token: Vec<u8>, pub workflow_namespace: String, pub workflow_type: Option<WorkflowType>, pub workflow_execution: Option<WorkflowExecution>, pub activity_type: Option<ActivityType>, pub activity_id: String, pub header: Option<Header>, pub input: Option<Payloads>, pub heartbeat_details: Option<Payloads>, pub scheduled_time: Option<Timestamp>, pub current_attempt_scheduled_time: Option<Timestamp>, pub started_time: Option<Timestamp>, pub attempt: i32, pub schedule_to_close_timeout: Option<Duration>, pub start_to_close_timeout: Option<Duration>, pub heartbeat_timeout: Option<Duration>, pub retry_policy: Option<RetryPolicy>,
Fields
task_token: Vec<u8>
workflow_namespace: String
workflow_type: Option<WorkflowType>
workflow_execution: Option<WorkflowExecution>
activity_type: Option<ActivityType>
activity_id: String
header: Option<Header>
input: Option<Payloads>
heartbeat_details: Option<Payloads>
scheduled_time: Option<Timestamp>
current_attempt_scheduled_time: Option<Timestamp>
started_time: Option<Timestamp>
attempt: i32
schedule_to_close_timeout: Option<Duration>
(– api-linter: core::0140::prepositions=disabled aip.dev/not-precedent: “to” is used to indicate interval. –)
start_to_close_timeout: Option<Duration>
(– api-linter: core::0140::prepositions=disabled aip.dev/not-precedent: “to” is used to indicate interval. –)
heartbeat_timeout: Option<Duration>
retry_policy: Option<RetryPolicy>
This is an actual retry policy the service uses. It can be different from the one provided (or not) during activity scheduling as the service can override the provided one in case its values are not specified or exceed configured system limits.
Trait Implementations
impl Clone for PollActivityTaskQueueResponse
[src]
fn clone(&self) -> PollActivityTaskQueueResponse
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for PollActivityTaskQueueResponse
[src]
impl Default for PollActivityTaskQueueResponse
[src]
impl Message for PollActivityTaskQueueResponse
[src]
fn encode_raw<B>(&self, buf: &mut B) where
B: BufMut,
[src]
B: BufMut,
fn merge_field<B>(
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
[src]
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
fn encoded_len(&self) -> usize
[src]
fn clear(&mut self)
[src]
pub fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
pub fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
pub fn decode<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
[src]
Self: Default,
B: Buf,
pub fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
[src]
Self: Default,
B: Buf,
pub fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
pub fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
impl PartialEq<PollActivityTaskQueueResponse> for PollActivityTaskQueueResponse
[src]
fn eq(&self, other: &PollActivityTaskQueueResponse) -> bool
[src]
fn ne(&self, other: &PollActivityTaskQueueResponse) -> bool
[src]
impl StructuralPartialEq for PollActivityTaskQueueResponse
[src]
Auto Trait Implementations
impl RefUnwindSafe for PollActivityTaskQueueResponse
impl Send for PollActivityTaskQueueResponse
impl Sync for PollActivityTaskQueueResponse
impl Unpin for PollActivityTaskQueueResponse
impl UnwindSafe for PollActivityTaskQueueResponse
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> FutureExt for T
[src]
pub fn with_context(self, otel_cx: Context) -> WithContext<Self>
[src]
pub fn with_current_context(self) -> WithContext<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Instrument for T
[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
pub fn into_request(self) -> Request<T>
[src]
impl<T> Pointable for T
pub const ALIGN: usize
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize
pub unsafe fn deref<'a>(ptr: usize) -> &'a T
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T
pub unsafe fn drop(ptr: usize)
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
pub fn to_owned(&self) -> T
[src]
pub fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
pub fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
pub fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,