Struct Prune 

pub struct Prune { /* private fields */ }

Taken by a job, as async fn forget_audits(prune: Prune, clock: Clock).

Implementations

impl Prune

pub async fn product_events(&self, before: Instant) -> Result<u64>

impl Prune

pub async fn before<A: Aggregate, T: Ordered + Clone + Send>( &self, column: Column<A, T>, before: T, ) -> Result<u64>

In batches, so no statement holds many rows’ locks and a retried job resumes; nulls stay.

Trait Implementations

impl Resolve<JobContext> for Prune

fn resolve( context: &mut JobContext, ) -> impl Future<Output = Result<Self>> + Send