Struct SsmService 

pub struct SsmService { /* private fields */ }

Implementations

impl SsmService

pub fn new(state: SharedSsmState) -> Self

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

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

pub fn with_kms_hook(self, hook: Arc<dyn KmsHook>) -> Self

pub fn set_command_status( &self, account_id: &str, command_id: &str, status: &str, ) -> bool

Admin: force a SendCommand result to a specific terminal status (e.g. “Failed”, “Cancelled”, “TimedOut”). Used by tests to simulate command failures without waiting on a real SSM agent. All invocations on the command move to the same status so GetCommandInvocation reflects the override on the next read. Returns true when the command was found and updated.

pub fn fail_command_invocation( &self, account_id: &str, command_id: &str, instance_id: Option<&str>, status_details: Option<&str>, standard_error_content: Option<&str>, ) -> usize

Admin: force a single invocation (or all if instance_id is None) to Failed with optional friendlier status_details and standard_error_content overrides. Mirrors what a real SSM agent would report when a runShellScript step exits non-zero. Returns the number of invocations that were updated.

pub fn parameter_policy_events( &self, account_id: &str, ) -> Vec<ParameterPolicyEvent>

Admin: read out the parameter-policy event log for the given account. Used by tests to verify that Expiration deletions and notification windows actually fired without standing up an EventBridge target. Reads also tick the lazy policy evaluator so callers don’t have to issue a Get* call first.

pub fn clear_parameter_policy_events(&self, account_id: &str)

Admin: drop the recorded parameter-policy event log for the given account. Tests use this to reset between assertions.

pub fn inject_session( &self, account_id: &str, target: &str, status: Option<&str>, owner: Option<&str>, reason: Option<&str>, session_id: Option<&str>, ) -> String

Admin: inject a fake SSM session record so DescribeSessions / TerminateSession round-trip without going through StartSession (which returns the Smithy-declared TargetNotConnected unless FAKECLOUD_SSM_SESSION_ECHO=1). The injected session is otherwise indistinguishable from one created by StartSession in echo mode. Returns the assigned SessionId.

Trait Implementations

impl AwsService for SsmService

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