Struct StepExecutionRecord 

pub struct StepExecutionRecord { /* private fields */ }

Implementations

impl StepExecutionRecord

pub fn pending() -> Self

pub fn pending_iteration(iteration: StepIteration) -> Self

pub fn pending_state_iteration(state_iteration: StateIteration) -> Self

pub fn pending_coordinates( state_iteration: StateIteration, iteration: StepIteration, ) -> Self

pub fn state_visit(&self) -> StateVisit

pub fn with_state_visit(self, state_visit: StateVisit) -> Self

pub fn state_iteration(&self) -> StateIteration

pub fn status(&self) -> StepStatus

pub fn iteration(&self) -> StepIteration

pub fn attempt(&self) -> StepAttempt

pub fn lease(&self) -> Option<&StepLease>

pub fn effective_lease_expires_at(&self) -> Option<OffsetDateTime>

pub fn output(&self) -> &StepOutput

pub fn error_message(&self) -> Option<&StepErrorMessage>

pub fn claimed_role(&self) -> Option<&RoleId>

pub fn budget_reservation_id(&self) -> Option<&BudgetReservationId>

pub fn can_be_started_at(&self, now: OffsetDateTime) -> bool

pub fn has_live_lease_at(&self, now: OffsetDateTime) -> bool

pub fn with_started( self, lease: StepLease, attempt: StepAttempt, claimed_role: Option<RoleId>, ) -> Self

pub fn with_budget_reservation( self, reservation_id: Option<BudgetReservationId>, ) -> Self

pub fn with_result(self, result: StepResult) -> Self

pub fn carried( output: StepOutput, source: SourceRecordRef, state_iteration: StateIteration, state_visit: StateVisit, ) -> Self

A completed record whose work was done in another instance.

Built rather than folded from a start and a result, because there was no start here: nothing was claimed, nothing was leased, and the attempt is the first this instance would make. The source is what keeps the distinction readable afterwards.

pub const fn carried_from(&self) -> Option<&SourceRecordRef>

Where this record’s work happened, when it was not here.

Trait Implementations

impl Clone for StepExecutionRecord

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 StepExecutionRecord

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StepExecutionRecord

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for StepExecutionRecord

impl PartialEq for StepExecutionRecord

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for StepExecutionRecord

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for StepExecutionRecord