Enum AppliedMutation 

pub enum AppliedMutation {
    TaskCreate {
        task_id: TaskId,
    },
    RunCreate {
        run_id: RunId,
        task_id: TaskId,
    },
    RunStateTransition {
        run_id: RunId,
        previous_state: RunState,
        new_state: RunState,
    },
    AttemptStart {
        run_id: RunId,
        attempt_id: AttemptId,
    },
    AttemptFinish {
        run_id: RunId,
        attempt_id: AttemptId,
        outcome: AttemptOutcome,
    },
    LeaseAcquire {
        run_id: RunId,
        owner: String,
        expiry: u64,
    },
    LeaseHeartbeat {
        run_id: RunId,
        owner: String,
        expiry: u64,
    },
    LeaseExpire {
        run_id: RunId,
        owner: String,
        expiry: u64,
    },
    LeaseRelease {
        run_id: RunId,
        owner: String,
        expiry: u64,
    },
    EnginePause,
    EngineResume,
    TaskCancel {
        task_id: TaskId,
    },
    DependencyDeclare {
        task_id: TaskId,
        depends_on: Vec<TaskId>,
    },
    RunSuspend {
        run_id: RunId,
    },
    RunResume {
        run_id: RunId,
    },
    BudgetAllocate {
        task_id: TaskId,
        dimension: BudgetDimension,
        limit: u64,
    },
    BudgetConsume {
        task_id: TaskId,
        dimension: BudgetDimension,
        amount: u64,
    },
    BudgetReplenish {
        task_id: TaskId,
        dimension: BudgetDimension,
        new_limit: u64,
    },
    SubscriptionCreate {
        subscription_id: SubscriptionId,
        task_id: TaskId,
    },
    SubscriptionCancel {
        subscription_id: SubscriptionId,
    },
    SubscriptionTrigger {
        subscription_id: SubscriptionId,
    },
    NoOp,
}

Applied semantic mutation metadata.

Variants

TaskCreate

Task specification was durably created.

Fields

task_id: TaskId

Created task identifier.

RunCreate

Run instance was durably created.

Fields

run_id: RunId

Created run identifier.

task_id: TaskId

Owning task identifier.

RunStateTransition

Run lifecycle transition was durably applied.

Fields

run_id: RunId

Run receiving the transition.

previous_state: RunState

Transition source state.

new_state: RunState

Transition target state.

AttemptStart

Attempt start was durably applied.

Fields

run_id: RunId

Run that owns the attempt.

attempt_id: AttemptId

Attempt that started.

AttemptFinish

Attempt finish was durably applied.

Fields

run_id: RunId

Run that owns the attempt.

attempt_id: AttemptId

Attempt that finished.

outcome: AttemptOutcome

Attempt outcome (result kind + optional error detail).

LeaseAcquire

Lease acquire was durably applied.

Fields

run_id: RunId

Run targeted by lease acquisition.

owner: String

Lease owner identity.

expiry: u64

Lease expiry timestamp.

LeaseHeartbeat

Lease heartbeat was durably applied.

Fields

run_id: RunId

Run targeted by lease heartbeat.

owner: String

Lease owner identity.

expiry: u64

Lease expiry timestamp after heartbeat.

LeaseExpire

Lease expiry was durably applied.

Fields

run_id: RunId

Run targeted by lease expiry.

owner: String

Lease owner identity.

expiry: u64

Lease expiry timestamp being expired.

LeaseRelease

Lease release was durably applied.

Fields

run_id: RunId

Run targeted by lease release.

owner: String

Lease owner identity.

expiry: u64

Lease expiry timestamp at release time.

EnginePause

Engine pause intent was durably applied.

EngineResume

Engine resume intent was durably applied.

TaskCancel

Task cancellation intent was durably applied.

Fields

task_id: TaskId

Task targeted by cancellation intent.

DependencyDeclare

Task dependency declarations were durably applied.

Fields

task_id: TaskId

Task whose promotion is gated.

depends_on: Vec<TaskId>

The prerequisite task identifiers.

RunSuspend

Run suspension was durably applied.

Fields

run_id: RunId

The suspended run.

RunResume

Run resumption was durably applied.

Fields

run_id: RunId

The resumed run.

BudgetAllocate

Budget allocation was durably applied.

Fields

task_id: TaskId

Task whose budget was allocated.

dimension: BudgetDimension

Dimension of the allocated budget.

limit: u64

Allocated limit.

BudgetConsume

Budget consumption was durably applied.

Fields

task_id: TaskId

Task whose budget was consumed.

dimension: BudgetDimension

Dimension consumed.

amount: u64

Amount consumed.

BudgetReplenish

Budget replenishment was durably applied.

Fields

task_id: TaskId

Task whose budget was replenished.

dimension: BudgetDimension

Dimension replenished.

new_limit: u64

New limit after replenishment.

SubscriptionCreate

Subscription creation was durably applied.

Fields

subscription_id: SubscriptionId

The created subscription.

task_id: TaskId

The subscribing task.

SubscriptionCancel

Subscription cancellation was durably applied.

Fields

subscription_id: SubscriptionId

The canceled subscription.

SubscriptionTrigger

Subscription trigger was durably applied.

Fields

subscription_id: SubscriptionId

The triggered subscription.

NoOp

No specific mutation outcome needed (actor/platform events).

Trait Implementations

impl Clone for AppliedMutation

fn clone(&self) -> AppliedMutation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AppliedMutation

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

Formats the value using the given formatter.

impl PartialEq for AppliedMutation

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

impl StructuralPartialEq for AppliedMutation