Struct ReportingProjector 

pub struct ReportingProjector;

Applies reporting facts inside the caller’s transaction and projector lock.

begin_rebuild opens a new generation with its cutoff and the in-progress marker; callers hold the source locks, so every fact minted before the cutoff has committed and every later one is above it and will be applied. clear_targets empties every report table and the revision guard for that generation, in a separate transaction so no source lock is held while the targets are truncated. finish_rebuild marks the baseline complete, leaving the cutoff as recorded by begin_rebuild or raised since by a privacy compaction — lowering it would replay facts that compaction has already delivered.

Implementations

impl ReportingProjector

pub async fn begin_rebuild( connection: &mut PgConnection, cutoff: i64, ) -> Result<i64>

pub async fn clear_targets( connection: &mut PgConnection, generation: i64, ) -> Result<()>

pub async fn finish_rebuild( connection: &mut PgConnection, generation: i64, ) -> Result<()>

pub async fn apply_fact( connection: &mut PgConnection, fact: &ReportingRow, ) -> Result<bool>

Trait Implementations

impl Clone for ReportingProjector

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for ReportingProjector

impl Debug for ReportingProjector

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

Formats the value using the given formatter.