Struct InMemoryPlanStore 

pub struct InMemoryPlanStore { /* private fields */ }

In-memory store for tests. Tracks status + applied routes per plan_id.

Implementations

impl InMemoryPlanStore

pub fn new() -> Self

Construct an empty store.

pub fn with_failing_route_write() -> Self

Construct a store whose PlanStore::mark_applied always fails the route write (and therefore the whole atomic operation). For tests that assert no audit row is emitted when persistence fails.

pub fn seed_projected(&self) -> Uuid

Seed a row in status='projected'. Returns the id for callers to pass to apply_plan.

pub fn status(&self, plan_id: Uuid) -> Option<String>

Read-only status lookup, used by tests to assert state transitions.

pub fn applied_at(&self, plan_id: Uuid) -> Option<DateTime<Utc>>

Read-only applied-at lookup.

pub fn applied_routes(&self, plan_id: Uuid) -> Option<Vec<ProposedRoute>>

Read-only lookup of the routes persisted by a successful apply. Used by tests to assert the proposed routes actually landed in the store (the heart of the rv-plan-apply-writes-routes fix).

Trait Implementations

impl Default for InMemoryPlanStore

fn default() -> InMemoryPlanStore

Returns the “default value” for a type.

impl PlanStore for InMemoryPlanStore

fn mark_applied<'life0, 'life1, 'async_trait>( &'life0 self, plan_id: Uuid, applied_at: DateTime<Utc>, routes: &'life1 [ProposedRoute], ) -> Pin<Box<dyn Future<Output = Result<Option<String>, ApplyError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Atomically (1) transition plan_id from status 'projected' to 'applied' and stamp applied_at, AND (2) persist routes to the Gateway routing config the live gateway reads. Return the previous status when the row exists, or None when no such row.