Struct raftstore::store::worker::region::PendingDeleteRanges

[+] Show declaration

struct PendingDeleteRanges {
    ranges: BTreeMap<Vec<u8>, StalePeerInfo>,
}

[−] Expand description

A structure records all ranges to be deleted with some delay. The delay is because there may be some coprocessor requests related to these ranges.

Fields

ranges: BTreeMap<Vec<u8>, StalePeerInfo>

Implementations

impl PendingDeleteRanges[−]

fn find_overlap_ranges(
    &self,
    start_key: &[u8],
    end_key: &[u8]
) -> Vec<(u64, Vec<u8>, Vec<u8>, u64)>[−]

Finds ranges that overlap with [start_key, end_key).

pub fn drain_overlap_ranges(
    &mut self,
    start_key: &[u8],
    end_key: &[u8]
) -> Vec<(u64, Vec<u8>, Vec<u8>, u64)>[−]

Gets ranges that overlap with [start_key, end_key).

fn remove(&mut self, start_key: &[u8]) -> Option<(u64, Vec<u8>, Vec<u8>)>[−]

Removes and returns the peer info with the start_key.

fn insert(
    &mut self,
    region_id: u64,
    start_key: &[u8],
    end_key: &[u8],
    stale_sequence: u64
)[−]

Inserts a new range waiting to be deleted.

Before an insert is called, it must call drain_overlap_ranges to clean the overlapping range.

pub fn stale_ranges(
    &self,
    oldest_sequence: u64
) -> impl Iterator<Item = (u64, &[u8], &[u8])>[−]

Gets all stale ranges info.

pub fn len(&self) -> usize

Trait Implementations

impl Clone for PendingDeleteRanges[+]

[+] Show hidden undocumented items

fn clone(&self) -> PendingDeleteRanges[−]

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Default for PendingDeleteRanges[+]

[+] Show hidden undocumented items

fn default() -> PendingDeleteRanges[−]

Returns the “default value” for a type.