Struct CloudFrontService 

pub struct CloudFrontService { /* private fields */ }

Implementations

impl CloudFrontService

pub fn new(state: SharedCloudFrontState) -> Self

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

pub fn shared_state(&self) -> SharedCloudFrontState

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

Build a hook that persists the current CloudFront 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 rearm_in_progress(&self)

Re-arm the propagation tick for any Distribution / DistributionTenant / ConnectionGroup / StreamingDistribution that was still InProgress when the previous process exited, so they still transition to Deployed after a restart. Called by the server after loading a snapshot.

pub fn with_propagation_delay(self, delay: Duration) -> Self

Override the propagation delay used by CreateDistribution, UpdateDistribution, and the equivalent DistributionTenant / ConnectionGroup ops. Tests pass a small duration so they don’t have to wait wall-clock seconds for the InProgress -> Deployed transition.

pub fn set_distribution_status(&self, id: &str, status: &str) -> bool

Flip a stored Distribution’s status synchronously. Returns false if no distribution matches id across any account. The admin endpoint POST /_fakecloud/cloudfront/distributions/{id}/status calls this so tests can force InProgress <-> Deployed without waiting on the propagation tick.

pub async fn set_distribution_status_persistent( &self, id: &str, status: &str, ) -> bool

Admin-endpoint flavour of set_distribution_status that persists the forced status so it survives a restart.

Trait Implementations

impl AwsService for CloudFrontService

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, req: 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 CloudFrontService

fn default() -> Self

Returns the “default value” for a type.