Trait ArchiverWriter 

pub trait ArchiverWriter: Send + Sync {
    // Required methods
    fn delete_events(&self, event_ids: &[i64]) -> Result<usize>;
    fn delete_commands(&self, command_ids: &[i64]) -> Result<usize>;
    fn delete_order_actions(&self, ids: &[i32]) -> Result<usize>;
    fn delete_order_updates(&self, ids: &[i32]) -> Result<usize>;
    fn delete_notifications_before(
        &self,
        cutoff: &DateTime<Utc>,
        batch_size: i64,
    ) -> Result<usize>;
    fn delete_notifications_over_per_user_cap(
        &self,
        max_per_user: i64,
        batch_size: i64,
    ) -> Result<usize>;
}

Write (delete) operations for the archiver: pruning archived rows.

Required Methods

fn delete_events(&self, event_ids: &[i64]) -> Result<usize>

Delete engine events by their IDs.

fn delete_commands(&self, command_ids: &[i64]) -> Result<usize>

Delete engine commands (and their digests) by their IDs.

fn delete_order_actions(&self, ids: &[i32]) -> Result<usize>

Delete order actions by their IDs.

fn delete_order_updates(&self, ids: &[i32]) -> Result<usize>

Delete order updates by their IDs.

fn delete_notifications_before( &self, cutoff: &DateTime<Utc>, batch_size: i64, ) -> Result<usize>

Delete a batch of notifications older than cutoff.

fn delete_notifications_over_per_user_cap( &self, max_per_user: i64, batch_size: i64, ) -> Result<usize>

Delete notifications that exceed the per-user cap.

Implementors