Struct CloudFormationService 

pub struct CloudFormationService { /* private fields */ }

The AWSim CloudFormation service handler.

Implementations

impl CloudFormationService

pub fn new() -> Self

Trait Implementations

impl Default for CloudFormationService

fn default() -> Self

Returns the “default value” for a type.

impl ServiceHandler for CloudFormationService

fn service_name(&self) -> &str

The AWS service name (e.g., “s3”, “sqs”, “dynamodb”).

fn signing_name(&self) -> &str

The signing name used in SigV4 Authorization headers. Usually the same as service_name, but not always.

fn protocol(&self) -> Protocol

The primary protocol this service uses.

fn handle<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, operation: &'life1 str, input: Value, ctx: &'life2 RequestContext, ) -> Pin<Box<dyn Future<Output = Result<Value, AwsError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Handle an AWS API operation.

fn routes(&self) -> Vec<RouteDefinition>

Route definitions for REST-protocol services. Not needed for RPC-style protocols (awsJson, awsQuery).

fn handle_streaming<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, operation: &'life1 str, input: Value, ctx: &'life2 RequestContext, ) -> Pin<Box<dyn Future<Output = Result<HandlerResult, AwsError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Streaming-aware variant. The default delegates to handle and wraps the JSON result so existing services don’t need to do anything; services that genuinely stream (Bedrock data plane) override this and return HandlerResult::Streaming.

fn snapshot(&self) -> Option<Vec<u8>>

Serialize the service’s state to bytes for persistence.

fn restore(&self, _data: &[u8]) -> Result<(), String>

Restore the service’s state from a previous snapshot.

fn rehydrate(&self) -> Result<(), String>

Called after every service has been restored from its snapshot, before the gateway begins serving traffic.

fn iam_action(&self, _operation: &str) -> Option<String>

fn iam_resource( &self, _operation: &str, _input: &Value, _ctx: &RequestContext, ) -> Option<String>

fn tick<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Periodic tick. The gateway spawns a single 1-second loop that calls tick on every registered service after the server is up. Use this hook for time-driven behavior that doesn’t fit into the request path: SQS visibility-timeout reclamation, DynamoDB TTL expiry, Lambda event-source-mapping polling, S3 lifecycle transitions, EventBridge schedule firing, SecretsManager rotation, etc.