Trait BackupRepository 

pub trait BackupRepository:
    Send
    + Sync
    + Debug {
    // Required methods
    fn initialize<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn store_metadata<'life0, 'life1, 'async_trait>(
        &'life0 self,
        metadata: &'life1 BackupMetadata,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn update_metadata<'life0, 'life1, 'async_trait>(
        &'life0 self,
        metadata: &'life1 BackupMetadata,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_latest_backup<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<Option<BackupMetadata>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_expired_backups<'life0, 'async_trait>(
        &'life0 self,
        retention_days: u32,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<BackupMetadata>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn get_recent_backups<'life0, 'async_trait>(
        &'life0 self,
        days: u32,
    ) -> Pin<Box<dyn Future<Output = Result<Vec<BackupMetadata>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn count_backups<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<u32>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn mark_backup_expired<'life0, 'life1, 'async_trait>(
        &'life0 self,
        backup_id: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn get_current_wal_lsn<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn verify_postgres_config<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

Repository abstraction for backup metadata operations

Required Methods

fn initialize<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn store_metadata<'life0, 'life1, 'async_trait>( &'life0 self, metadata: &'life1 BackupMetadata, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn update_metadata<'life0, 'life1, 'async_trait>( &'life0 self, metadata: &'life1 BackupMetadata, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_latest_backup<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<BackupMetadata>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_expired_backups<'life0, 'async_trait>( &'life0 self, retention_days: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<BackupMetadata>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn get_recent_backups<'life0, 'async_trait>( &'life0 self, days: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<BackupMetadata>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn count_backups<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<u32>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn mark_backup_expired<'life0, 'life1, 'async_trait>( &'life0 self, backup_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn get_current_wal_lsn<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn verify_postgres_config<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl BackupRepository for MockBackupRepository

impl BackupRepository for PostgresBackupRepository