Skip to main content

MultiAccountState

Struct MultiAccountState 

Source
pub struct MultiAccountState<T> { /* private fields */ }
Expand description

Account-partitioned state container.

Holds one T per account id. The default_account_id is pre-created at startup so unauthenticated requests (which fall back to --account-id) always have a state to land in.

Implementations§

Source§

impl<T: AccountState> MultiAccountState<T>

Source

pub fn new(default_account_id: &str, region: &str, endpoint: &str) -> Self

Create a new container, pre-populating the default account.

Source

pub fn get_or_create(&mut self, account_id: &str) -> &mut T

Get or lazily create the state for account_id.

When a new account is created, AccountState::inherit_from is called with the default account’s state so services can propagate shared resources (e.g. body caches).

Source

pub fn get_or_create_with<F>(&mut self, account_id: &str, init: F) -> &mut T
where F: FnOnce(&mut T),

Get or lazily create the state for account_id, then run init on the newly created state. The callback is only invoked when the account is freshly created, not on subsequent lookups.

Source

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

Read-only lookup. Returns None if the account has never been seen.

Source

pub fn get_mut(&mut self, account_id: &str) -> Option<&mut T>

Mutable lookup without auto-creation.

Source

pub fn iter(&self) -> impl Iterator<Item = (&str, &T)>

Iterate over all account states (read-only).

Source

pub fn iter_mut(&mut self) -> impl Iterator<Item = (&str, &mut T)>

Iterate over all account states (mutable).

Source

pub fn default_account_id(&self) -> &str

The default account id configured via --account-id.

Source

pub fn default_mut(&mut self) -> &mut T

Mutable reference to the default account’s state (always exists).

Source

pub fn default_ref(&self) -> &T

Reference to the default account’s state (always exists).

Source

pub fn reset(&mut self)

Reset all accounts back to empty state. The default account is recreated; all other accounts are dropped.

Source

pub fn find_account<F>(&self, predicate: F) -> Option<&str>
where F: Fn(&T) -> bool,

Find the first account whose state satisfies predicate and return the account id. Useful for resolving globally-unique resources (e.g. S3 bucket names) back to their owning account.

Source

pub fn account_count(&self) -> usize

Number of accounts with state.

Source

pub fn region(&self) -> &str

Region shared by all accounts.

Source

pub fn endpoint(&self) -> &str

Endpoint shared by all accounts.

Trait Implementations§

Source§

impl<T: Clone> Clone for MultiAccountState<T>

Source§

fn clone(&self) -> MultiAccountState<T>

Returns a duplicate of the value. Read more
1.0.0 (const: unstable) · Source§

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

Performs copy-assignment from source. Read more
Source§

impl<T: Debug> Debug for MultiAccountState<T>

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<'de, T> Deserialize<'de> for MultiAccountState<T>
where T: Deserialize<'de>,

Source§

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>
where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer. Read more
Source§

impl<T> Serialize for MultiAccountState<T>
where T: Serialize,

Source§

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>
where __S: Serializer,

Serialize this value into the given Serde serializer. Read more

Auto Trait Implementations§

§

impl<T> Freeze for MultiAccountState<T>

§

impl<T> RefUnwindSafe for MultiAccountState<T>
where T: RefUnwindSafe,

§

impl<T> Send for MultiAccountState<T>
where T: Send,

§

impl<T> Sync for MultiAccountState<T>
where T: Sync,

§

impl<T> Unpin for MultiAccountState<T>
where T: Unpin,

§

impl<T> UnsafeUnpin for MultiAccountState<T>

§

impl<T> UnwindSafe for MultiAccountState<T>
where T: UnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<T> DeserializeOwned for T
where T: for<'de> Deserialize<'de>,

Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T> FromRef<T> for T
where T: Clone,

Source§

fn from_ref(input: &T) -> T

Converts to this type from a reference to the input type.
Source§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,

Source§

impl<T> Instrument for T

Source§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more
Source§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> Same for T

Source§

type Output = T

Should always be Self
Source§

impl<T> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V

Source§

impl<T> WithSubscriber for T

Source§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more
Source§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more