Struct temporal_sdk_core::protos::temporal::api::workflowservice::v1::PollActivityTaskQueueResponse

pub struct PollActivityTaskQueueResponse {

    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

fn clone(&self) -> PollActivityTaskQueueResponse

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PollActivityTaskQueueResponse

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PollActivityTaskQueueResponse

fn default() -> Self

Returns the “default value” for a type.

impl Message for PollActivityTaskQueueResponse

fn encode_raw<B>(&self, buf: &mut B) where
    B: BufMut, 

fn merge_field<B>(
    &mut self,
    tag: u32,
    wire_type: WireType,
    buf: &mut B,
    ctx: DecodeContext
) -> Result<(), DecodeError> where
    B: Buf, 

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

pub fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message to a buffer.

pub fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message with a length-delimiter to a buffer.

pub fn decode<B>(buf: B) -> Result<Self, DecodeError> where
    Self: Default,
    B: Buf, 

Decodes an instance of the message from a buffer.

pub fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
    Self: Default,
    B: Buf, 

Decodes a length-delimited instance of the message from the buffer.

pub fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes an instance of the message from a buffer, and merges it into self.

pub fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq<PollActivityTaskQueueResponse> for PollActivityTaskQueueResponse

fn eq(&self, other: &PollActivityTaskQueueResponse) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &PollActivityTaskQueueResponse) -> bool

This method tests for !=.

impl StructuralPartialEq for PollActivityTaskQueueResponse