Struct IdentityStateStore 

pub struct IdentityStateStore<S> { /* private fields */ }

Adapter-neutral persistence helper over the protocol’s scoped CAS store.

Implementations

impl<S> IdentityStateStore<S>

pub fn new(store: S) -> Self

pub fn inner(&self) -> &S

impl<S: StateStore> IdentityStateStore<S>

pub async fn read( &self, scope: &S::Scope, key: &str, ) -> Result<IdentityStateSnapshot, IdentityError>

scope must bind tenant, upstream and principal; keys must also bind the conversation/invocation. A wire dialect is not an upstream identity.

pub async fn save( &self, scope: &S::Scope, key: &str, expected: Option<Version>, record: &IdentityStateRecord, expires_at: Option<SystemTime>, ) -> Result<Version, IdentityError>

Save a record with compare-and-exchange. expected = None creates a fresh scope key; callers should perform this before exposing an alias.

pub async fn update_late( &self, scope: &S::Scope, key: &str, expected: Version, facts: LateIdentityFacts, ) -> Result<IdentityStateSnapshot, IdentityError>

CAS update for source ids/signatures that arrive after an alias was emitted. Existing aliases remain untouched in the record.