Struct KeepsakeRepository 

pub struct KeepsakeRepository<C = NoopRelationCache> { /* private fields */ }

SQLx-backed keepsake repository.

Implementations

impl KeepsakeRepository<NoopRelationCache>

pub const fn new(pool: PgPool) -> Self

Creates a repository from a Postgres pool.

impl<C> KeepsakeRepository<C>

where C: RelationCache,

pub const fn at(&self, at: DateTime<Utc>) -> TimedKeepsakeRepository<'_, C>

Creates a timestamp-scoped repository view.

Use this at request or job boundaries to keep one explicit clock read while avoiding repeated timestamp plumbing through related repository calls.

pub fn with_relation_cache<Next>(self, cache: Next) -> KeepsakeRepository<Next>

where Next: RelationCache,

Enables relation definition caching for read helper methods.

pub fn with_local_relation_cache( self, config: LocalRelationCacheConfig, ) -> KeepsakeRepository<LocalRelationCache>

Enables local in-process relation definition caching for read helper methods.

pub async fn migrate(&self) -> RepositoryResult<()>

Runs embedded migrations.

pub async fn upsert_relation( &self, relation: &RelationDefinition, at: DateTime<Utc>, ) -> RepositoryResult<RelationDefinition>

Inserts or updates a relation definition by its natural relation key.

If a relation already exists for the same kind/name, its stable id is preserved and the returned definition contains the existing id.

pub async fn upsert_relation_spec<Spec>( &self, at: DateTime<Utc>, ) -> RepositoryResult<RelationDefinition>

where Spec: RelationSpec,

Inserts or updates a typed relation spec by its natural relation key.

pub async fn relation_by_id( &self, relation_id: RelationId, ) -> RepositoryResult<Option<RelationDefinition>>

Looks up a relation definition by stable id.

pub async fn relation_by_key( &self, key: &RelationKey, ) -> RepositoryResult<Option<RelationDefinition>>

Looks up a relation definition by its natural relation key.

pub async fn set_relation_enabled( &self, relation_id: RelationId, enabled: bool, at: DateTime<Utc>, ) -> RepositoryResult<bool>

Enables or disables a relation.

pub async fn apply( &self, subject: &SubjectRef, relation_id: RelationId, at: DateTime<Utc>, metadata: &BTreeMap<String, String>, ) -> RepositoryResult<AppliedKeepsake>

Applies a keepsake relation idempotently.

If an active keepsake already exists for the subject and relation, the existing row is returned with duplicate_prevented set to true, even if the relation has since been disabled. Disabled relations reject new non-duplicate applies.

pub async fn apply_spec<Spec>( &self, subject: &SubjectRef, at: DateTime<Utc>, metadata: &BTreeMap<String, String>, ) -> RepositoryResult<AppliedKeepsake>

where Spec: RelationSpec,

Applies a typed keepsake relation idempotently.

pub async fn apply_without_metadata( &self, subject: &SubjectRef, relation_id: RelationId, at: DateTime<Utc>, ) -> RepositoryResult<AppliedKeepsake>

Applies a keepsake relation with empty metadata.

pub async fn apply_spec_without_metadata<Spec>( &self, subject: &SubjectRef, at: DateTime<Utc>, ) -> RepositoryResult<AppliedKeepsake>

where Spec: RelationSpec,

Applies a typed keepsake relation with empty metadata.

pub async fn revoke( &self, keepsake_id: Uuid, at: DateTime<Utc>, ) -> RepositoryResult<bool>

Revokes an active keepsake.

pub async fn active_for_subject( &self, subject: &SubjectRef, ) -> RepositoryResult<Vec<Keepsake>>

Returns active keepsakes for a subject.

pub async fn active_relations_for_subject( &self, subject: &SubjectRef, ) -> RepositoryResult<Vec<ActiveRelation>>

Returns active keepsakes for a subject with their relation definitions.

pub async fn active_relations_for_subject_by_keys( &self, subject: &SubjectRef, keys: &[RelationKey], ) -> RepositoryResult<Vec<ActiveRelation>>

Returns active keepsakes for a subject, filtered by relation keys.

This is the bounded variant of Self::active_relations_for_subject for request paths that know the small set of relation keys they care about. Missing keys are ignored, and disabled relation definitions are still returned when their keepsake is active.

pub async fn active_membership_scan( &self, relation_id: RelationId, limit: i64, ) -> RepositoryResult<Vec<Keepsake>>

Scans active memberships for a relation in stable order.

pub async fn active_membership_scan_after( &self, relation_id: RelationId, after: Option<&MembershipCursor>, limit: i64, ) -> RepositoryResult<Vec<Keepsake>>

Scans active memberships after a keyset cursor in stable order.

pub async fn due_timed_expiry( &self, now: DateTime<Utc>, limit: i64, ) -> RepositoryResult<Vec<TimedExpiryCandidate>>

Lists due timed expiry candidates in stable batch order.

pub async fn expire_due_timed( &self, now: DateTime<Utc>, limit: i64, ) -> RepositoryResult<u64>

Expires a stable batch of due timed keepsakes.

pub async fn upsert_counter_projection( &self, keepsake_id: Uuid, key: &str, value: i64, observed_at: DateTime<Utc>, ) -> RepositoryResult<()>

Upserts a simple fulfillment counter projection.

Trait Implementations

impl<C: Clone> Clone for KeepsakeRepository<C>

fn clone(&self) -> KeepsakeRepository<C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for KeepsakeRepository<C>

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

Formats the value using the given formatter.