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>,
}

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.

Implementations

impl EcsState

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

pub fn reset(&mut self)

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.