Struct InMemoryEcs 

pub struct InMemoryEcs { /* private fields */ }

In-memory fake target for unit tests + the conformance bench.

Records the side effects so tests can assert what landed. task_set_stability reports stable immediately, so the warm readiness wait resolves on the first poll (the timeout path is exercised by a scripted fake in deployer.rs).

Implementations

impl InMemoryEcs

pub fn services(&self) -> BTreeSet<DeploymentId>

Snapshot of the ensured services.

pub fn task_sets(&self) -> BTreeMap<(DeploymentId, RevisionId), TaskSetHandle>

Snapshot of the live task sets.

pub fn weights_for( &self, deployment_id: DeploymentId, ) -> Option<Vec<TargetGroupWeight>>

Snapshot of the last-applied weights for a deployment.

pub fn routing_for( &self, deployment_id: DeploymentId, ) -> Option<Option<ListenerRouting>>

Snapshot of the routing the last apply_listener_weights carried for a deployment. Outer None = no listener write recorded; inner None = a default-action write; inner Some = a per-deployment rule.

Trait Implementations

impl Debug for InMemoryEcs

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

Formats the value using the given formatter.

impl Default for InMemoryEcs

fn default() -> InMemoryEcs

Returns the “default value” for a type.

impl EcsDeployTarget for InMemoryEcs

fn ensure_service<'life0, 'life1, 'async_trait>( &'life0 self, spec: &'life1 ServiceSpec, ) -> Pin<Box<dyn Future<Output = Result<(), EcsTargetError>> + Send + 'async_trait>>

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

Create the per-deployment EXTERNAL-controller service if absent. Idempotent: a second call against an existing service is Ok.

fn create_task_set<'life0, 'life1, 'async_trait>( &'life0 self, spec: &'life1 TaskSetSpec, ) -> Pin<Box<dyn Future<Output = Result<TaskSetHandle, EcsTargetError>> + Send + 'async_trait>>

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

Register the revision’s task definition + create its task set. Idempotent: re-creating a task set for an existing (deployment, revision) returns the existing TaskSetHandle without registering a second definition.

fn task_set_stability<'life0, 'life1, 'async_trait>( &'life0 self, _task_set: &'life1 TaskSetRef, ) -> Pin<Box<dyn Future<Output = Result<TaskSetStability, EcsTargetError>> + Send + 'async_trait>>

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

Poll a task set’s rollout status (steady state + target-group health).

fn delete_task_set<'life0, 'life1, 'async_trait>( &'life0 self, task_set: &'life1 TaskSetRef, ) -> Pin<Box<dyn Future<Output = Result<(), EcsTargetError>> + Send + 'async_trait>>

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

Delete a task set and deregister its task definition. Idempotent against an already-absent set.

fn apply_listener_weights<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, listener: &'life1 ListenerRef, weights: &'life2 [TargetGroupWeight], ) -> Pin<Box<dyn Future<Output = Result<(), EcsTargetError>> + Send + 'async_trait>>

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

Set the listener’s weighted forward action across the deployment’s task-set target groups (the ALB mirror of the env’s TrafficSplit).