Struct Ec2Service 

pub struct Ec2Service { /* private fields */ }

Amazon EC2 service.

Implementations

impl Ec2Service

pub fn new() -> Self

Construct a service over a fresh, empty account-partitioned state.

pub fn with_state(state: SharedEc2State) -> Self

Construct a service over a shared state handle (used by the server so persistence/snapshots can be wired in later batches).

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

Synchronous dispatch for the subset of EC2 control-plane actions the CloudFormation provisioner needs (VPC/Subnet/SecurityGroup/RouteTable/ InternetGateway create + delete). Routing through the real handlers keeps CFN-provisioned EC2 resources identical to API-created ones (default SG/NACL/route-table, id formats, tags) instead of re-deriving them. None of these actions need the container runtime.

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

Attach a container runtime so RunInstances boots real containers. Passing None leaves the service in metadata-only mode.

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

Attach a persistence snapshot store so control-plane mutations are written through to disk. Backing containers are reconciled separately on restart via Ec2Service::recover_persisted_containers.

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

Build a hook that persists the current EC2 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, the same way a direct mutating API call would.

pub fn shared_state(&self) -> SharedEc2State

Clone the shared state handle so the server can expose read-only introspection endpoints (GET /_fakecloud/ec2/instances).

pub async fn recover_persisted_containers(&self)

Rebuild the backing-container runtime state for persisted instances after a fakecloud restart, mirroring RDS/ElastiCache recover_persisted_containers.

On an ungraceful restart the new process has a new PID, so the shared reaper removes every EC2 container labeled with the previous PID; an instance that persisted as running with a container_id would otherwise be left pointing at a removed container, with every subsequent Stop/Start/Reboot/Terminate a silent no-op (bug-hunt 2026-06-15 finding 0.3). For each such instance we flip it to pending and spawn a fresh backing container in the background, reconciling it to running (with the new id/IP) when it’s up, or stopped on failure. Instances persisted as stopped/terminated are left as-is — StartInstances revives the former. No-op when no runtime is configured or there are no instances to recover.

Trait Implementations

impl AwsService for Ec2Service

fn service_name(&self) -> &str

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

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

List of actions this service supports (for introspection).

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 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).

impl Default for Ec2Service

fn default() -> Self

Returns the “default value” for a type.