Struct PendingActivityInfo 

pub struct PendingActivityInfo {

    pub activity_id: String,
    pub activity_type: Option<ActivityType>,
    pub state: i32,
    pub heartbeat_details: Option<Payloads>,
    pub last_heartbeat_time: Option<Timestamp>,
    pub last_started_time: Option<Timestamp>,
    pub attempt: i32,
    pub maximum_attempts: i32,
    pub scheduled_time: Option<Timestamp>,
    pub expiration_time: Option<Timestamp>,
    pub last_failure: Option<Failure>,
    pub last_worker_identity: String,
    pub last_worker_version_stamp: Option<WorkerVersionStamp>,
    pub current_retry_interval: Option<Duration>,
    pub last_attempt_complete_time: Option<Timestamp>,
    pub next_attempt_schedule_time: Option<Timestamp>,
    pub paused: bool,
    pub last_deployment: Option<Deployment>,
    pub last_worker_deployment_version: String,
    pub last_deployment_version: Option<WorkerDeploymentVersion>,
    pub priority: Option<Priority>,
    pub pause_info: Option<PauseInfo>,
    pub activity_options: Option<ActivityOptions>,
    pub assigned_build_id: Option<AssignedBuildId>,
}

Fields

activity_id: String

activity_type: Option<ActivityType>

state: i32

heartbeat_details: Option<Payloads>

last_heartbeat_time: Option<Timestamp>

last_started_time: Option<Timestamp>

attempt: i32

maximum_attempts: i32

scheduled_time: Option<Timestamp>

expiration_time: Option<Timestamp>

last_failure: Option<Failure>

last_worker_identity: String

last_worker_version_stamp: Option<WorkerVersionStamp>

👎Deprecated

Deprecated. The version stamp of the worker to whom this activity was most recently dispatched This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]

current_retry_interval: Option<Duration>

The time activity will wait until the next retry. If activity is currently running it will be next retry interval if activity failed. If activity is currently waiting it will be current retry interval. If there will be no retry it will be null.

last_attempt_complete_time: Option<Timestamp>

The time when the last activity attempt was completed. If activity has not been completed yet then it will be null.

next_attempt_schedule_time: Option<Timestamp>

Next time when activity will be scheduled. If activity is currently scheduled or started it will be null.

paused: bool

Indicates if activity is paused.

last_deployment: Option<Deployment>

👎Deprecated

The deployment this activity was dispatched to most recently. Present only if the activity was dispatched to a versioned worker. Deprecated. Use last_deployment_version.

last_worker_deployment_version: String

👎Deprecated

The Worker Deployment Version this activity was dispatched to most recently. Deprecated. Use last_deployment_version.

last_deployment_version: Option<WorkerDeploymentVersion>

The Worker Deployment Version this activity was dispatched to most recently. If nil, the activity has not yet been dispatched or was last dispatched to an unversioned worker.

priority: Option<Priority>

Priority metadata. If this message is not present, or any fields are not present, they inherit the values from the workflow.

pause_info: Option<PauseInfo>

activity_options: Option<ActivityOptions>

Current activity options. May be different from the one used to start the activity.

assigned_build_id: Option<AssignedBuildId>

Absence of assigned_build_id generally means this task is on an “unversioned” task queue. In rare cases, it can also mean that the task queue is versioned but we failed to write activity’s independently-assigned build ID to the database. This case heals automatically once the task is dispatched. Deprecated. This field should be cleaned up when versioning-2 API is removed. [cleanup-experimental-wv]

Implementations

impl PendingActivityInfo

pub fn state(&self) -> PendingActivityState

Returns the enum value of state, or the default if the field is set to an invalid enum value.

pub fn set_state(&mut self, value: PendingActivityState)

Sets state to the provided enum value.

Trait Implementations

impl Clone for PendingActivityInfo

fn clone(&self) -> PendingActivityInfo

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingActivityInfo

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

Formats the value using the given formatter.

impl Default for PendingActivityInfo

fn default() -> Self

Returns the “default value” for a type.

impl Message for PendingActivityInfo

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 PendingActivityInfo

const NAME: &'static str = "PendingActivityInfo"

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

fn eq(&self, other: &PendingActivityInfo) -> 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 PendingActivityInfo

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 PendingActivityInfo