Struct raftstore::coprocessor::region_info_accessor::RegionInfoAccessor

[+] Show declaration

pub struct RegionInfoAccessor {
    worker: Worker,
    scheduler: Scheduler<RegionInfoQuery>,
}

[−] Expand description

RegionInfoAccessor keeps all region information separately from raftstore itself.

Fields

worker: Worker

scheduler: Scheduler<RegionInfoQuery>

Implementations

impl RegionInfoAccessor[−]

pub fn new(host: &mut CoprocessorHost<impl KvEngine>) -> Self[−]

Creates a new RegionInfoAccessor and register to host. RegionInfoAccessor doesn’t need, and should not be created more than once. If it’s needed in different places, just clone it, and their contents are shared.

pub fn stop(&self)[−]

Stops the RegionInfoAccessor. It should be stopped after raftstore.

pub fn debug_dump(&self) -> (HashMap<u64, RegionInfo>, BTreeMap<Vec<u8>, u64>)[−]

Gets all content from the collection. Only used for testing.

Trait Implementations

impl Clone for RegionInfoAccessor[+]

[+] Show hidden undocumented items

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl RegionInfoProvider for RegionInfoAccessor[+]

[+] Show hidden undocumented items

fn seek_region(&self, from: &[u8], callback: SeekRegionCallback) -> Result<()>[−]

Get a iterator of regions that contains from or have keys larger than from, and invoke the callback to process the result.

fn find_region_by_id(
    &self,
    region_id: u64,
    callback: Callback<Option<RegionInfo>>
) -> Result<()>

fn get_regions_in_range(
    &self,
    start_key: &[u8],
    end_key: &[u8]
) -> Result<Vec<Region>>