Struct Start 

pub struct Start {

    pub workflow_namespace: String,
    pub workflow_type: String,
    pub workflow_execution: Option<WorkflowExecution>,
    pub activity_id: String,
    pub activity_type: String,
    pub header_fields: HashMap<String, Payload>,
    pub input: Vec<Payload>,
    pub heartbeat_details: Vec<Payload>,
    pub scheduled_time: Option<Timestamp>,
    pub current_attempt_scheduled_time: Option<Timestamp>,
    pub started_time: Option<Timestamp>,
    pub attempt: u32,
    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 priority: Option<Priority>,
    pub is_local: bool,
}

Begin executing an activity

Fields

workflow_namespace: String

The namespace the workflow lives in

workflow_type: String

The workflow’s type name or function identifier

workflow_execution: Option<WorkflowExecution>

The workflow execution which requested this activity

activity_id: String

The activity’s ID

activity_type: String

The activity’s type name or function identifier

header_fields: HashMap<String, Payload>

input: Vec<Payload>

Arguments to the activity

heartbeat_details: Vec<Payload>

The last details that were recorded by a heartbeat when this task was generated

scheduled_time: Option<Timestamp>

When the task was first scheduled

current_attempt_scheduled_time: Option<Timestamp>

When this current attempt at the task was scheduled

started_time: Option<Timestamp>

When this attempt was started, which is to say when core received it by polling.

attempt: u32

schedule_to_close_timeout: Option<Duration>

Timeout from the first schedule time to completion

start_to_close_timeout: Option<Duration>

Timeout from starting an attempt to reporting its result

heartbeat_timeout: Option<Duration>

If set a heartbeat must be reported within this interval

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.

priority: Option<Priority>

Priority of this activity. Local activities will always have this field set to the default.

is_local: bool

Set to true if this is a local activity. Note that heartbeating does not apply to local activities.

Trait Implementations

impl Clone for Start

fn clone(&self) -> Start

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Start

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

Formats the value using the given formatter.

impl Default for Start

fn default() -> Self

Returns the “default value” for a type.

impl Message for Start

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 Start

const NAME: &'static str = "Start"

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 = "coresdk.activity_task"

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 Start

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

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 Start