Struct FeedbackFactsRepository 

pub struct FeedbackFactsRepository { /* private fields */ }

Implementations

impl FeedbackFactsRepository

pub async fn begin_backfill( &self, owner: &UserId, job: &TaskId, source: &str, ) -> Result<BackfillProgress>

pub async fn backfill( &self, owner: &UserId, job: &TaskId, ) -> Result<BackfillProgress>

pub async fn append_backfill_page( &self, owner: &UserId, job: &TaskId, page: &BackfillPage, ) -> Result<BackfillProgress>

impl FeedbackFactsRepository

pub async fn claim_deltas( &self, owner: &UserId, consumer: &str, worker: &AnalyticsWorkerId, claim: DeltaClaim, ) -> Result<Option<DeltaLease>>

pub async fn delta_batch( &self, owner: &UserId, lease: &DeltaLease, ) -> Result<Vec<FactDelta>>

pub async fn lock_delta_lease( tx: &mut Transaction<'_, Postgres>, owner: &UserId, lease: &DeltaLease, ) -> Result<()>

pub async fn complete_delta_batch( tx: &mut Transaction<'_, Postgres>, owner: &UserId, lease: &DeltaLease, ) -> Result<()>

impl FeedbackFactsRepository

pub async fn apply( &self, owner: &UserId, lease: &FactLease, ) -> Result<ApplyOutcome>

impl FeedbackFactsRepository

pub async fn claim( &self, owner: &UserId, worker: &AnalyticsWorkerId, limit: u32, lease_seconds: u32, ) -> Result<Vec<FactLease>>

pub async fn retry(&self, owner: &UserId, lease: &FactLease) -> Result<()>

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

impl FeedbackFactsRepository

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

pub async fn submit( &self, owner: &UserId, change: &AnalyticsChange, ) -> Result<ChangeReceipt>

pub async fn submit_in( tx: &mut Transaction<'_, Postgres>, owner: &UserId, change: &AnalyticsChange, ) -> Result<ChangeReceipt>

pub async fn get_fact( &self, owner: &UserId, key: &AnalyticsFactKey, ) -> Result<Option<StoredFact>>

pub async fn list_facts( &self, owner: &UserId, after: Option<&AnalyticsFactKey>, limit: u32, ) -> Result<Vec<StoredFact>>

pub async fn change_status( &self, owner: &UserId, id: &AnalyticsChangeId, ) -> Result<Option<ChangeDiagnostic>>

impl FeedbackFactsRepository

pub async fn reference_totals( &self, owner: &UserId, from: DateTime<Utc>, to: DateTime<Utc>, resource: Option<&ManagedResourceId>, ) -> Result<FactsTotals>

Trait Implementations

impl Clone for FeedbackFactsRepository

fn clone(&self) -> FeedbackFactsRepository

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FeedbackFactsRepository

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

Formats the value using the given formatter.