Struct StepFunctionsService 

pub struct StepFunctionsService { /* private fields */ }

Implementations

impl StepFunctionsService

pub fn new(state: SharedStepFunctionsState) -> Self

pub fn with_delivery(self, delivery: Arc<DeliveryBus>) -> Self

pub fn with_dynamodb(self, dynamodb_state: SharedDynamoDbState) -> Self

pub fn with_registry(self, registry: SharedServiceRegistry) -> Self

Hand the service a deferred-fill handle to the central ServiceRegistry. main.rs calls [OnceLock::set] on the inner cell after every service has been registered; until then the interpreter falls back to its hand-coded SDK integrations (lambda invoke, sqs sendMessage, …).

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

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

Build a hook that persists the current Step Functions state when invoked, or None in memory mode (no snapshot store). 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.

Trait Implementations

impl AwsService for StepFunctionsService

fn service_name(&self) -> &str

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

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 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_actions_for(&self, request: &AwsRequest) -> Vec<IamAction>

Every IAM authorization an incoming request needs.

fn iam_resource_in_caller_account(&self, _request: &AwsRequest) -> bool

Whether the request creates its resource in the CALLER’s account, so that whatever currently holds the resource’s name elsewhere has no say in authorizing it. S3’s CreateBucket is the case: bucket names are global, and creating a name another account owns is authorized against the caller’s own policies (then answered BucketAlreadyExists), never against the other account’s bucket policy. Dispatch then evaluates the request as same-account with no resource policy. Default false.

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