Struct EcsService 

pub struct EcsService { /* private fields */ }

Implementations

impl EcsService

pub fn run_task_external( &self, account_id: &str, cluster: &str, task_definition: &str, launch_type: Option<&str>, count: usize, ) -> Result<(), String>

Spawn a task from a cross-service caller (EventBridge Scheduler / EventBridge Rules) without going through the AwsRequest dispatch path. Builds the JSON body and reuses Self::run_task so all the existing validation / runtime spawn logic runs identically. Returns Err with a human-readable message on validation failures — the caller decides whether to surface the failure (e.g. DLQ).

pub fn run_task( &self, request: &AwsRequest, ) -> Result<AwsResponse, AwsServiceError>

impl EcsService

pub fn new(state: SharedEcsState) -> Self

pub fn with_snapshot_store(self, store: Arc<dyn SnapshotStore>) -> Self

pub fn with_runtime(self, runtime: Arc<EcsRuntime>) -> Self

pub fn with_role_trust_validator( self, validator: Arc<dyn RoleTrustValidator>, ) -> Self

pub fn state_handle(&self) -> &SharedEcsState

pub fn snapshot_hook(&self) -> Option<SnapshotHook>

Build a hook that persists the current state when invoked, or None in memory mode. The CloudFormation provisioner mutates state directly and uses this to write a CFN-provisioned resource through to disk.

pub async fn reconcile_persisted_tasks(&self)

Reconcile persisted task state with reality after a fakecloud restart. Same bug class as RDS #1338: tasks were persisted with lastStatus = RUNNING but their docker containers are gone, so DescribeTasks reported phantom-running tasks and docker exec (for ECS Exec) would fail.

Mark every non-STOPPED task as STOPPED with a stoppedReason that explains the restart, and reset service runningCount / pendingCount to zero. The service scheduler ticker then reconciles desiredCount and launches fresh tasks. Standalone RunTask tasks aren’t auto-respawned because we don’t have enough context to replay them safely; callers re-invoke.

pub async fn reconcile_service_desired_counts(&self)

Converge every ACTIVE service toward its desiredCount, launching replacement tasks for any shortfall. Real ECS maintains desiredCount autonomously; reconcile_persisted_tasks STOPs all tasks and zeroes counts on restart “trusting a scheduler ticker,” but no such ticker existed, so services with desiredCount=N stayed at runningCount=0 forever. This is that ticker. It also re-launches tasks lost to crashed containers during normal operation. bug-audit 2026-06-15, 4.7.

One pass: for each service, count its non-STOPPED tasks (matched by the ecs-svc/<name> started_by tag, same as recompute_service_counts); if that count is below desiredCount, spawn the difference via the shared spawn_service_tasks path and hand the new task IDs to the runtime. Persist only when something was launched.

Trait Implementations

impl AwsService for EcsService

fn service_name(&self) -> &str

The AWS service identifier (e.g., “sqs”, “sns”, “sts”, “events”, “ssm”).

fn handle<'life0, 'async_trait>( &'life0 self, request: AwsRequest, ) -> Pin<Box<dyn Future<Output = Result<AwsResponse, AwsServiceError>> + Send + 'async_trait>>

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

Handle an incoming request.

fn supported_actions(&self) -> &[&str]

List of actions this service supports (for introspection).

fn iam_enforceable(&self) -> bool

Whether this service participates in opt-in IAM enforcement (FAKECLOUD_IAM=soft|strict).

fn iam_action_for(&self, _request: &AwsRequest) -> Option<IamAction>

Derive the IAM action + resource ARN for an incoming request.

fn iam_condition_keys_for( &self, _request: &AwsRequest, _action: &IamAction, ) -> BTreeMap<String, Vec<String>>

Derive service-specific IAM condition keys for an incoming request.

fn resource_tags_for( &self, _resource_arn: &str, ) -> Option<HashMap<String, String>>

Return the tags on the resource identified by resource_arn.

fn request_tags_from( &self, _request: &AwsRequest, _action: &str, ) -> Option<HashMap<String, String>>

Extract tags being sent in the request (e.g. on CreateQueue, PutObject with x-amz-tagging, TagResource).