Struct EcsState 

pub struct EcsState {

    pub account_id: String,
    pub region: String,
    pub clusters: BTreeMap<String, Cluster>,
    pub task_definitions: BTreeMap<String, BTreeMap<i32, TaskDefinition>>,
    pub next_revision: BTreeMap<String, i32>,
    pub account_setting_defaults: BTreeMap<String, String>,
    pub principal_account_settings: BTreeMap<String, BTreeMap<String, String>>,
    pub tasks: BTreeMap<String, Task>,
    pub events: Vec<LifecycleEvent>,
    pub services: BTreeMap<String, Service>,
    pub container_instances: BTreeMap<String, ContainerInstance>,
    pub attributes: BTreeMap<String, Attribute>,
    pub capacity_providers: BTreeMap<String, CapacityProvider>,
    pub task_sets: BTreeMap<String, TaskSet>,
    pub daemon_task_definitions: BTreeMap<String, BTreeMap<i32, DaemonTaskDefinition>>,
    pub next_daemon_revision: BTreeMap<String, i32>,
    pub daemons: BTreeMap<String, Daemon>,
    pub daemon_deployments: BTreeMap<String, DaemonDeployment>,
    pub express_gateway_services: BTreeMap<String, ExpressGatewayService>,
    pub service_revisions: BTreeMap<String, ServiceRevision>,
}

Fields

account_id: String

region: String

clusters: BTreeMap<String, Cluster>

Cluster state keyed by cluster name.

task_definitions: BTreeMap<String, BTreeMap<i32, TaskDefinition>>

Task definitions keyed by family -> revision -> definition. ECS revisions monotonically increase per-family regardless of deregistration, so we track the running counter separately.

next_revision: BTreeMap<String, i32>

Running revision counter per family. Grows monotonically even after task definitions are deregistered or deleted.

account_setting_defaults: BTreeMap<String, String>

Account-default settings (PutAccountSettingDefault). Keyed by setting name (e.g. serviceLongArnFormat).

principal_account_settings: BTreeMap<String, BTreeMap<String, String>>

Per-principal account settings (PutAccountSetting). Keyed by principal ARN, then setting name.

tasks: BTreeMap<String, Task>

Tasks keyed by task ID (the trailing segment of the task ARN).

events: Vec<LifecycleEvent>

Lifecycle event log for introspection. Bounded at 1024 entries (oldest dropped) so long-running servers don’t grow unboundedly.

services: BTreeMap<String, Service>

Services keyed by service name within an account. ECS requires unique service names per cluster, and since service names are already unique per-cluster globally we scope keys by cluster_name:service_name in EcsState::service_key.

container_instances: BTreeMap<String, ContainerInstance>

Container instances keyed by cluster/arn-suffix. Users register EC2 hosts here; fakecloud still runs tasks via Docker regardless, but the control-plane records remain so DescribeContainerInstances round-trips.

attributes: BTreeMap<String, Attribute>

Custom attributes keyed by cluster/target-arn-or-id/name.

capacity_providers: BTreeMap<String, CapacityProvider>

Capacity providers keyed by name.

task_sets: BTreeMap<String, TaskSet>

Task sets keyed by cluster/service/task-set-id.

daemon_task_definitions: BTreeMap<String, BTreeMap<i32, DaemonTaskDefinition>>

Daemon task definitions keyed by family -> revision -> definition. Same shape as task_definitions but isolated since daemon defs use the dedicated RegisterDaemonTaskDefinition op and have their own revision counter.

next_daemon_revision: BTreeMap<String, i32>

Per-family monotonic revision counter for daemon task defs.

daemons: BTreeMap<String, Daemon>

Daemons keyed by cluster/daemon-name. Daemons are cluster-scoped and run one task per matching capacity provider per AWS spec.

daemon_deployments: BTreeMap<String, DaemonDeployment>

Daemon deployment history keyed by deployment ARN. Each CreateDaemon / UpdateDaemon mints a new deployment record.

express_gateway_services: BTreeMap<String, ExpressGatewayService>

Express Gateway services keyed by cluster/service-name. The 2026 Express Gateway feature is a serverless container service with built-in load balancing and autoscaling.

service_revisions: BTreeMap<String, ServiceRevision>

Service revisions keyed by serviceRevisionArn ({service_arn}:{n}). A revision is minted on CreateService and on each UpdateService that changes the task definition, so DescribeServiceRevisions can return the real configuration snapshot instead of an empty stub.

Implementations

impl EcsState

pub fn new(account_id: &str, region: &str) -> Self

pub fn reset(&mut self)

pub fn record_service_revision(&mut self, service: &Service) -> String

Mint and store a new service revision for service, numbered by how many revisions already exist for that service ({service_arn}:{n}). Returns the new serviceRevisionArn.

pub fn service_key(cluster_name: &str, service_name: &str) -> String

Services are uniquely identified by (cluster, name) within an account; this helper composes the storage key used in self.services.

pub fn service_arn(&self, cluster_name: &str, service_name: &str) -> String

pub fn task_arn(&self, cluster_name: &str, task_id: &str) -> String

pub fn container_instance_arn( &self, cluster_name: &str, instance_id: &str, ) -> String

pub fn effective_account_setting( &self, name: &str, principal_arn: Option<&str>, ) -> Option<String>

Resolve the effective value of an account setting. Principal overrides win over account-level defaults, matching AWS’s PutAccountSetting / PutAccountSettingDefault layering. With no principal_arn argument the caller gets the account default.

pub fn push_event(&mut self, event: LifecycleEvent)

Append a lifecycle event, trimming the oldest when the cap is hit.

pub fn cluster_arn(&self, cluster_name: &str) -> String

pub fn task_definition_arn(&self, family: &str, revision: i32) -> String

pub fn resolve_cluster_name(input: Option<&str>) -> String

Given a user-supplied cluster reference (name or ARN), return the cluster name. Defaults to "default" when None/empty, matching the AWS CLI behaviour.

pub fn allocate_revision(&mut self, family: &str) -> i32

Bump and return the next revision number for a family. Never reused: monotonically increases even across deregistration.

impl EcsState

pub fn daemon_key(cluster: &str, name: &str) -> String

Composite key for daemon storage (cluster_name/daemon_name).

pub fn express_gateway_key(cluster: &str, name: &str) -> String

Composite key for express-gateway storage (cluster_name/service_name).

pub fn allocate_daemon_revision(&mut self, family: &str) -> i32

Allocate the next monotonic revision for a daemon task family.

pub fn daemon_arn(&self, cluster: &str, name: &str) -> String

Build a daemon ARN for a (cluster, name) pair under this account/region.

pub fn express_gateway_arn(&self, cluster: &str, name: &str) -> String

Build an express-gateway service ARN.

pub fn daemon_task_definition_arn(&self, family: &str, revision: i32) -> String

Build a daemon task definition ARN for a family:revision pair.

pub fn daemon_deployment_arn( &self, daemon_name: &str, deployment_id: &str, ) -> String

Build a daemon deployment ARN.

Trait Implementations

impl AccountState for EcsState

fn new_for_account(account_id: &str, region: &str, _endpoint: &str) -> Self

Create a fresh, empty state for the given account.

fn inherit_from(&mut self, _sibling: &Self)

Called after a new account state is created via MultiAccountState::get_or_create, with a reference to an existing sibling state. Services can override this to propagate shared resources (e.g. body caches) to the new state.

impl Clone for EcsState

fn clone(&self) -> EcsState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EcsState

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

Formats the value using the given formatter.

impl Default for EcsState

fn default() -> EcsState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for EcsState

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for EcsState

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

where __S: Serializer,

Serialize this value into the given Serde serializer.