Struct 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>,
    pub poller_scaling_decision: Option<PollerScalingDecision>,
    pub priority: Option<Priority>,
    pub activity_run_id: String,
}

Fields

task_token: Vec<u8>

A unique identifier for this task

workflow_namespace: String

The namespace of the activity. If this is a workflow activity then this is the namespace of the workflow also. If this is a standalone activity then the name of this field is misleading, but retained for compatibility with workflow activities.

workflow_type: Option<WorkflowType>

Type of the requesting workflow (if this is a workflow activity).

workflow_execution: Option<WorkflowExecution>

Execution info of the requesting workflow (if this is a workflow activity)

activity_type: Option<ActivityType>

activity_id: String

The autogenerated or user specified identifier of this activity. Can be used to complete the activity via RespondActivityTaskCompletedById. May be re-used as long as the last usage has resolved, but unique IDs for every activity invocation is a good idea. Note that only a workflow activity ID may be autogenerated.

header: Option<Header>

Headers specified by the scheduling workflow. Commonly used to propagate contextual info from the workflow to its activities. For example, tracing contexts.

input: Option<Payloads>

Arguments to the activity invocation

heartbeat_details: Option<Payloads>

Details of the last heartbeat that was recorded for this activity as of the time this task was delivered.

scheduled_time: Option<Timestamp>

When was this task first scheduled

current_attempt_scheduled_time: Option<Timestamp>

When was this task attempt scheduled

started_time: Option<Timestamp>

When was this task started (this attempt)

attempt: i32

Starting at 1, the number of attempts to perform this activity

schedule_to_close_timeout: Option<Duration>

First scheduled -> final result reported timeout

(– api-linter: core::0140::prepositions=disabled aip.dev/not-precedent: “to” is used to indicate interval. –)

start_to_close_timeout: Option<Duration>

Current attempt start -> final result reported timeout

(– api-linter: core::0140::prepositions=disabled aip.dev/not-precedent: “to” is used to indicate interval. –)

heartbeat_timeout: Option<Duration>

Window within which the activity must report a heartbeat, or be timed out.

retry_policy: Option<RetryPolicy>

This is the retry policy the service uses which may be different from the one provided (or not) during activity scheduling. The service can override the provided one if some values are not specified or exceed configured system limits.

poller_scaling_decision: Option<PollerScalingDecision>

Server-advised information the SDK may use to adjust its poller count.

priority: Option<Priority>

Priority metadata

activity_run_id: String

The run ID of the activity execution, only set for standalone activities.

Implementations

impl PollActivityTaskQueueResponse

pub fn sched_to_start(&self) -> Option<Duration>

Return the duration of the task schedule time (current attempt) to its start time if both are set and time went forward.

Trait Implementations

impl Clone for PollActivityTaskQueueResponse

fn clone(&self) -> PollActivityTaskQueueResponse

Returns a duplicate of the value.

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 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.

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

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

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

where Self: Sized,

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

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

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

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

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

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

where Self: Sized,

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

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

where Self: Sized,

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

impl Name for PollActivityTaskQueueResponse

const NAME: &'static str = "PollActivityTaskQueueResponse"

Simple name for this Message. This name is the same as it appears in the source .proto file, e.g. FooBar.

const PACKAGE: &'static str = "temporal.api.workflowservice.v1"

Package name this message type is contained in. They are domain-like and delimited by ., e.g. google.protobuf.

fn full_name() -> String

Fully-qualified unique name for this 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.

fn type_url() -> String

Type URL for this Message, which by default is the full name with a leading slash, but may also include a leading domain name, e.g. type.googleapis.com/google.profile.Person. This can be used when serializing into the google.protobuf.Any type.

impl PartialEq for PollActivityTaskQueueResponse

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl PayloadVisitable for PollActivityTaskQueueResponse

fn visit_payloads_mut<'a>( &'a mut self, visitor: &'a mut (dyn AsyncPayloadVisitor + Send), ) -> BoxFuture<'a, ()>

Visit all payload fields in this message. The visitor is called once per field, receiving the field’s payload(s).

impl StructuralPartialEq for PollActivityTaskQueueResponse