Struct TimedSqlxKeepsakeRepository 

pub struct TimedSqlxKeepsakeRepository<'repo, B, C = NoopRelationCache>
where
    B: KeepsakeSqlxBackend,
{ /* private fields */ }

Timestamp-scoped repository view.

This wrapper does not read the system clock. Callers choose the timestamp once at an operation boundary, then use the forwarding methods to keep related writes and expiry scans on the same deterministic instant.

Implementations

impl<'repo, B, C> TimedSqlxKeepsakeRepository<'repo, B, C>

where B: KeepsakeSqlxBackend,

pub const fn repository(&self) -> &'repo SqlxKeepsakeRepository<B, C>

Returns the repository backing this timestamp-scoped view.

pub const fn timestamp(&self) -> DateTime<Utc>

Returns the timestamp applied by forwarding methods.

impl<C> TimedSqlxKeepsakeRepository<'_, PostgresBackend, C>

where C: RelationCache,

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

Inserts or updates a relation definition using this view’s timestamp.

pub async fn upsert_relation_spec<Spec>( &self, ) -> RepositoryResult<RelationDefinition>

where Spec: RelationSpec,

Inserts or updates a typed relation spec using this view’s timestamp.

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

Enables or disables a relation using this view’s timestamp.

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

Lists due timed expiry candidates using this view’s timestamp.

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

Expires a stable batch of due timed keepsakes using this view’s timestamp.

pub async fn fulfillment_snapshot( &self, keepsake_id: Uuid, ) -> RepositoryResult<FulfillmentSnapshot>

Reads the persisted fulfillment counter snapshot for a keepsake.

pub async fn due_fulfilled_expiry( &self, limit: i64, ) -> RepositoryResult<Vec<FulfilledExpiryCandidate>>

Lists fulfillment expiry candidates.

pub async fn expire_due_fulfilled(&self, limit: i64) -> RepositoryResult<u64>

Expires fulfillment-satisfied keepsakes using this view’s timestamp.

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

Upserts a simple fulfillment counter projection using this view’s timestamp.

pub async fn increment_counter_projection( &self, keepsake_id: Uuid, key: &str, delta: i64, ) -> RepositoryResult<i64>

Atomically increments a fulfillment counter using this view’s timestamp.

pub async fn upsert_checklist_projection( &self, keepsake_id: Uuid, item: &str, complete: bool, ) -> RepositoryResult<()>

Upserts a checklist item completion projection using this view’s timestamp.

Trait Implementations

impl<'repo, B, C: Clone> Clone for TimedSqlxKeepsakeRepository<'repo, B, C>

where B: KeepsakeSqlxBackend + Clone,

fn clone(&self) -> TimedSqlxKeepsakeRepository<'repo, B, C>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'repo, B, C: Copy> Copy for TimedSqlxKeepsakeRepository<'repo, B, C>

where B: KeepsakeSqlxBackend + Copy,

impl<'repo, B, C: Debug> Debug for TimedSqlxKeepsakeRepository<'repo, B, C>

where B: KeepsakeSqlxBackend + Debug,

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

Formats the value using the given formatter.