Struct AccountRegionStore 

pub struct AccountRegionStore<T: Default + Send + Sync + 'static> { /* private fields */ }

A thread-safe, account+region-namespaced state store.

Each AWS service uses this to store its state, ensuring that resources in different accounts/regions are isolated.

Example:

let store = AccountRegionStore::<SqsState>::new();
let state = store.get("000000000000", "us-east-1");
state.queues.insert("my-queue".into(), queue);

Implementations

impl<T: Default + Send + Sync + 'static> AccountRegionStore<T>

pub fn new() -> Self

pub fn get(&self, account_id: &str, region: &str) -> Arc<T>

Get or create the state for a given account+region pair.

pub fn clear(&self)

Clear all state (useful for testing).

pub fn iter_all(&self) -> Vec<((String, String), Arc<T>)>

Iterate over all (account_id, region) → state entries.

Returns a snapshot of the keys paired with the Arc<T> values so the caller can read state without holding any DashMap locks long-term.

pub fn set(&self, account_id: &str, region: &str, value: T)

Insert a state value for the given (account_id, region), replacing any existing entry.

impl<T: Snapshottable + Default + 'static> AccountRegionStore<T>

pub fn snapshot_to_bytes(&self) -> Option<Vec<u8>>

pub fn restore_from_bytes(&self, data: &[u8]) -> Result<(), String>

Trait Implementations

impl<T: Default + Send + Sync + 'static> Clone for AccountRegionStore<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug + Default + Send + Sync + 'static> Debug for AccountRegionStore<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: Default + Send + Sync + 'static> Default for AccountRegionStore<T>

fn default() -> Self

Returns the “default value” for a type.