Struct EcsRuntime 

pub struct EcsRuntime { /* private fields */ }

Docker/Podman executor for ECS tasks.

Implementations

impl EcsRuntime

pub fn with_secretsmanager(self, state: SharedSecretsManagerState) -> Self

Wire SecretsManager state so secrets[].valueFrom entries pointing at SecretsManager ARNs resolve at task launch.

pub fn with_ssm(self, state: SharedSsmState) -> Self

Wire SSM state so secrets[].valueFrom entries pointing at Parameter Store ARNs resolve at task launch.

impl EcsRuntime

pub fn run_task( self: Arc<Self>, state: SharedEcsState, task_id: String, account_id: String, )

Spawn the task asynchronously. Returns immediately after transitioning the task to PENDING; the background task advances it to RUNNING once the container is created and to STOPPED once the container exits.

pub async fn run_task_inner( &self, state: &SharedEcsState, task_id: &str, account_id: &str, ) -> Result<(), RuntimeError>

pub async fn stop_task(&self, task_id: &str, reason: &str) -> bool

Kill every container behind a task with the configured stop timeout. Returns true if at least one container was killed. Called synchronously from StopTask; the wait loop in run_task_inner observes the exits and transitions the task to STOPPED.

pub async fn stop_all(&self)

Kill every running container the runtime owns. Called on reset / shutdown so docker state matches fakecloud state after a fresh boot.

impl EcsRuntime

pub fn new(server_port: u16) -> Option<Self>

Auto-detect Docker or Podman. Returns None if neither is available. Honours FAKECLOUD_CONTAINER_CLI for explicit override. server_port is the port the main fakecloud server bound to; needed to resolve AWS ECR URIs against the local OCI v2 registry.

pub async fn new_k8s(server_port: u16) -> Result<Self, BackendInitError>

Construct the Kubernetes backend. server_port is fakecloud’s bound port (used when FAKECLOUD_K8S_SELF_URL omits one). Fails fast on misconfiguration — never silently degrades to Docker.

pub fn cli_name(&self) -> &str

Backend name for logging.

pub async fn reap_stale(&self)

Sweep task Pods orphaned by a previous process (k8s only; no-op on the Docker backend, handled by the shared container reaper).

pub fn with_delivery_bus(self, bus: Arc<DeliveryBus>) -> Self

Wire EventBridge delivery so task state transitions emit aws.ecs / ECS Task State Change events.

pub fn with_logs(self, logs: SharedLogsState) -> Self

Wire CloudWatch Logs state so tasks using the awslogs driver get their captured stdout/stderr forwarded.