Struct BackupManager 

pub struct BackupManager {
    env: MetaSrvEnv,
    hummock_manager: HummockManagerRef,
    backup_store: ArcSwap<(ObjectStoreMetaSnapshotStorage, (String, String))>,
    running_job_handle: Mutex<Option<BackupJobHandle>>,
    metrics: BackupManagerMetrics,
    meta_metrics: Arc<MetaMetrics>,
    latest_job_info: ArcSwap<(MetaBackupJobId, BackupJobStatus, String)>,
}

BackupManager manages lifecycle of all existent backups and the running backup job.

Fields

env: MetaSrvEnv

hummock_manager: HummockManagerRef

backup_store: ArcSwap<(ObjectStoreMetaSnapshotStorage, (String, String))>

running_job_handle: Mutex<Option<BackupJobHandle>>

Tracks the running backup job. Concurrent jobs is not supported.

metrics: BackupManagerMetrics

meta_metrics: Arc<MetaMetrics>

latest_job_info: ArcSwap<(MetaBackupJobId, BackupJobStatus, String)>

(job id, status, message)

Implementations

impl BackupManager

pub async fn new( env: MetaSrvEnv, hummock_manager: HummockManagerRef, metrics: Arc<MetaMetrics>, store_url: &str, store_dir: &str, ) -> MetaResult<Arc<Self>>

async fn handle_new_config(&self, new_config: (String, String))

fn with_store( env: MetaSrvEnv, hummock_manager: HummockManagerRef, meta_metrics: Arc<MetaMetrics>, backup_store: (ObjectStoreMetaSnapshotStorage, (String, String)), ) -> Self

pub async fn set_store(&self, config: (String, String)) -> MetaResult<()>

pub async fn start_backup_job( self: &Arc<Self>, remarks: Option<String>, ) -> MetaResult<MetaBackupJobId>

Starts a backup job in background. It’s non-blocking. Returns job id.

pub fn get_backup_job_status( &self, job_id: MetaBackupJobId, ) -> (BackupJobStatus, String)

async fn finish_backup_job( &self, job_id: MetaBackupJobId, job_result: BackupJobResult, )

async fn take_job_handle_by_job_id( &self, job_id: u64, ) -> Option<BackupJobHandle>

pub async fn delete_backups(&self, ids: &[MetaSnapshotId]) -> MetaResult<()>

Deletes existent backups from backup storage.

pub fn list_pinned_object_ids(&self) -> HashSet<HummockRawObjectId>

List id of all objects required by backups.

pub fn manifest(&self) -> Arc<MetaSnapshotManifest>