Struct PoolRespawn 

pub struct PoolRespawn {
    promoted_label: String,
    refilled_label: Option<String>,
    phase: Phase,
}

Pool-respawn saga: fires once per promote, waits for the matching refill, then completes.

Fields

promoted_label: String

Label of the window that was promoted (Step 1’s input). Held for log correlation only — the saga doesn’t validate the new pool label against this one. Kept on the struct so future failure-mode logging (timeout / explicit fail) can include “which promote did this saga belong to?” without rethreading. LSD-2 — also surfaces in --diag sagas via input_snapshot.

refilled_label: Option<String>

New pool label observed in Event::PoolWindowAdded (Step 2’s output). None until refill is observed.

phase: Phase

Implementations

impl PoolRespawn

pub fn new(promoted_label: String) -> Self

Construct a fresh saga for a promote of promoted_label. Coordinator allocates the saga_id and calls start once.

Trait Implementations

impl Saga for PoolRespawn

fn input_snapshot(&self) -> Value

LSD-2 — record the promote’s source label for --diag sagas. refilled_label is None at start (only known after Step 2’s echo lands) so we don’t include it; the durable log captures the inputs the saga was constructed with, not its evolving state — that lives in step rows.

fn name(&self) -> &'static str

fn start(&mut self, _ctx: &SagaCtx) -> SagaAction

fn on_event(&mut self, event: &Event, ctx: &SagaCtx) -> SagaAction

fn timeout(&self) -> Duration

CPD-3 — per-saga deadline budget for completing all IssueCmd+wait cycles. Coordinator arms a timer when the saga registers; if the saga is still in_flight when timeout() elapses, it is force-failed (SagaFailed { reason: "saga timeout" }) and removed from the registry.