Struct StepMethodEventContext 

pub struct StepMethodEventContext {

    pub step_execution_id: String,
    pub from_step_execution_id: String,
    pub step_type: String,
    pub durability: i32,
    pub final_attempt: i32,
    pub started_time: Option<Timestamp>,
    pub duration: Option<Duration>,
    pub method_options: Option<StepMethodOptions>,
    pub last_failure_info: Option<StepMethodFailure>,
    pub pull_routing: Option<PullRouting>,
    pub from_event_id: i64,
    pub wait_for_completed_event_id: i64,
    pub wait_for_completed_time: Option<Timestamp>,
}

Fields

step_execution_id: String

from_step_execution_id: String

step_type: String

durability: i32

final_attempt: i32

started_time: Option<Timestamp>

duration: Option<Duration>

method_options: Option<StepMethodOptions>

last_failure_info: Option<StepMethodFailure>

pull_routing: Option<PullRouting>

from_event_id: i64

The event ID of the history event that started this Step execution.

The event depends on what started the Step execution:

• The start Step: the FlowStartedOrContinued event.
• A Step decision: the StepExecuteCompleted event of from_step_execution_id.
• A failure recovery Step: the StepExecuteFailed event of from_step_execution_id.
• An RPC Step decision: the RpcExecutionCompleted event. Every event of the Step execution carries the same value.

Use it to link a Step execution to its source without scanning history. The event can be on another history page. It can also belong to an earlier run attempt of the lineage after time travel. When the ID is inside GetHistoryEventsResponse.pruned_event_id_range, the history window removed the event.

Zero when no history event started the Step execution, such as for the Flow timeout handler. Zero also for events that a Server recorded before it reported this field. Then find the source through from_step_execution_id.

wait_for_completed_event_id: i64

The event ID of the StepWaitForCompleted event of this Step execution.

It is set only on Execute events: StepExecuteCompleted, StepExecuteFailed, and StepExecutePending. The Step’s WaitFor must have completed. Use it to link Execute to the WaitFor that registered its waiting conditions. The event can be on another history page, or in an earlier run attempt of the lineage after time travel. When the ID is inside GetHistoryEventsResponse.pruned_event_id_range, the history window removed the event.

Zero on WaitFor events. Zero also when the Step skipped WaitFor, or when WaitFor failed and the Step proceeded to Execute. Zero also for events that a Server recorded before it reported this field. Then find the WaitFor event through step_execution_id.

wait_for_completed_time: Option<Timestamp>

The event time of the StepWaitForCompleted event that wait_for_completed_event_id names.

It stays available after the history window removes that event. The time from it to started_time is not only the condition wait. started_time is the start of the attempt that this event reports, so the difference also includes Execute dispatch and lock waits, and every earlier failed Execute attempt with its retry backoff. On a StepExecutePending event in the SCHEDULED phase whose Execute never started an attempt, started_time is when Execute was first scheduled, not an attempt start.

Unset whenever wait_for_completed_event_id is zero.

Implementations

impl StepMethodEventContext

pub fn durability(&self) -> StepDurability

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

pub fn set_durability(&mut self, value: StepDurability)

Sets durability to the provided enum value.

Trait Implementations

impl Clone for StepMethodEventContext

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StepMethodEventContext

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

Formats the value using the given formatter.

impl Default for StepMethodEventContext

fn default() -> Self

Returns the “default value” for a type.

impl Message for StepMethodEventContext

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 PartialEq for StepMethodEventContext

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StepMethodEventContext