Struct raftstore::coprocessor::region_info_accessor::RegionInfoAccessor

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

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

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

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>>