Struct FeedbackSnapshotsRepository 

pub struct FeedbackSnapshotsRepository { /* private fields */ }

PostgreSQL persistence for retained snapshots, jobs, and coordinated compaction.

Implementations

impl FeedbackSnapshotsRepository

pub async fn request_range( &self, owner: &UserId, request: &SnapshotRangeRequest, now: DateTime<Utc>, ) -> Result<SnapshotRangeJob>

pub async fn range_job( &self, owner: &UserId, job: &AnalyticsSnapshotJobId, ) -> Result<Option<SnapshotRangeJob>>

pub async fn claim_range( &self, owner: &UserId, worker: &AnalyticsWorkerId, ) -> Result<Option<SnapshotJobLease>>

pub async fn complete_range( &self, owner: &UserId, lease: &SnapshotJobLease, now: DateTime<Utc>, ) -> Result<()>

pub async fn fail_range( &self, owner: &UserId, lease: &SnapshotJobLease, diagnostic: &str, ) -> Result<()>

impl FeedbackSnapshotsRepository

pub async fn process( &self, owner: &UserId, worker: &AnalyticsWorkerId, now: DateTime<Utc>, ) -> Result<u64>

pub async fn apply_batch( &self, owner: &UserId, lease: &DeltaLease, now: DateTime<Utc>, ) -> Result<u64>

impl FeedbackSnapshotsRepository

pub async fn refresh( &self, owner: &UserId, resources: &[ManagedResourceId], now: DateTime<Utc>, ) -> Result<i64>

pub async fn snapshot( &self, owner: &UserId, resource: Option<&ManagedResourceId>, window: u32, ) -> Result<Option<FeedbackSnapshot>>

pub async fn snapshots( &self, owner: &UserId, after: Option<&ManagedResourceId>, window: u32, limit: u32, ) -> Result<Vec<FeedbackSnapshot>>

pub async fn health(&self, owner: &UserId) -> Result<SnapshotHealth>

impl FeedbackSnapshotsRepository

pub async fn compact_in( tx: &mut Transaction<'_, Postgres>, owner: &UserId, now: DateTime<Utc>, ) -> Result<RetentionOutcome>

impl FeedbackSnapshotsRepository

pub async fn compact_all_in( tx: &mut Transaction<'_, Postgres>, now: DateTime<Utc>, ) -> Result<RetentionSummary>

impl FeedbackSnapshotsRepository

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

Trait Implementations

impl Clone for FeedbackSnapshotsRepository

fn clone(&self) -> FeedbackSnapshotsRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FeedbackSnapshotsRepository

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

Formats the value using the given formatter.