Struct raftstore::store::SnapManager

pub struct SnapManager {
    core: SnapManagerCore,
    max_total_size: AtomicU64,
}

SnapManagerCore trace all current processing snapshots.

Fields

core: SnapManagerCore

max_total_size: AtomicU64

Implementations

impl SnapManager

pub fn new<T: Into<String>>(path: T) -> Self

pub fn init(&self) -> Result<()>

pub fn list_idle_snap(&self) -> Result<Vec<(SnapKey, bool)>>

pub fn get_temp_path_for_ingest(&self) -> String

pub fn has_registered(&self, key: &SnapKey) -> bool

pub fn get_snapshot_for_building<EK: KvEngine>(
    &self,
    key: &SnapKey
) -> RaftStoreResult<Box<dyn Snapshot<EK>>>

pub fn get_snapshot_for_gc(
    &self,
    key: &SnapKey,
    is_sending: bool
) -> RaftStoreResult<Box<dyn GenericSnapshot>>

pub fn get_snapshot_for_sending(
    &self,
    key: &SnapKey
) -> RaftStoreResult<Box<dyn GenericSnapshot>>

pub fn get_snapshot_for_receiving(
    &self,
    key: &SnapKey,
    data: &[u8]
) -> RaftStoreResult<Box<dyn GenericSnapshot>>

fn get_concrete_snapshot_for_applying(
    &self,
    key: &SnapKey
) -> RaftStoreResult<Box<Snap>>

pub fn get_snapshot_for_applying(
    &self,
    key: &SnapKey
) -> RaftStoreResult<Box<dyn GenericSnapshot>>

pub fn get_snapshot_for_applying_to_engine<EK: KvEngine>(
    &self,
    key: &SnapKey
) -> RaftStoreResult<Box<dyn Snapshot<EK>>>

pub fn get_total_snap_size(&self) -> Result<u64, Error>

Get the approximate size of snap file exists in snap directory.

Return value is not guaranteed to be accurate.

NOTE: don’t call it in raftstore thread.

pub fn max_total_snap_size(&self) -> u64

pub fn set_max_total_snap_size(&self, max_total_size: u64)

pub fn set_speed_limit(&self, bytes_per_sec: f64)

pub fn get_speed_limit(&self) -> f64

pub fn register(&self, key: SnapKey, entry: SnapEntry)

pub fn deregister(&self, key: &SnapKey, entry: &SnapEntry)

pub fn stats(&self) -> SnapStats

pub fn delete_snapshot(
    &self,
    key: &SnapKey,
    snap: &dyn GenericSnapshot,
    check_entry: bool
) -> bool

Trait Implementations

impl Clone for SnapManager

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.