Struct test_raftstore::pd::Cluster

struct Cluster {
    meta: Cluster,
    stores: HashMap<u64, Store>,
    regions: BTreeMap<Key, Region>,
    region_id_keys: HashMap<u64, Key>,
    region_approximate_size: HashMap<u64, u64>,
    region_approximate_keys: HashMap<u64, u64>,
    region_last_report_ts: HashMap<u64, UnixSecs>,
    region_last_report_term: HashMap<u64, u64>,
    base_id: AtomicUsize,
    store_stats: HashMap<u64, StoreStats>,
    store_hotspots: HashMap<u64, HashMap<u64, PeerStat>>,
    split_count: usize,
    operators: HashMap<u64, Operator>,
    enable_peer_count_check: bool,
    leaders: HashMap<u64, Peer>,
    down_peers: HashMap<u64, PeerStats>,
    pending_peers: HashMap<u64, Peer>,
    is_bootstraped: bool,
    gc_safe_point: u64,
    replication_status: Option<ReplicationStatus>,
    region_replication_status: HashMap<u64, RegionReplicationStatus>,
    pub check_merge_target_integrity: bool,
}

Fields

meta: Cluster

stores: HashMap<u64, Store>

regions: BTreeMap<Key, Region>

region_id_keys: HashMap<u64, Key>

region_approximate_size: HashMap<u64, u64>

region_approximate_keys: HashMap<u64, u64>

region_last_report_ts: HashMap<u64, UnixSecs>

region_last_report_term: HashMap<u64, u64>

base_id: AtomicUsize

store_stats: HashMap<u64, StoreStats>

store_hotspots: HashMap<u64, HashMap<u64, PeerStat>>

split_count: usize

operators: HashMap<u64, Operator>

enable_peer_count_check: bool

leaders: HashMap<u64, Peer>

down_peers: HashMap<u64, PeerStats>

pending_peers: HashMap<u64, Peer>

is_bootstraped: bool

gc_safe_point: u64

replication_status: Option<ReplicationStatus>

region_replication_status: HashMap<u64, RegionReplicationStatus>

check_merge_target_integrity: bool

Implementations

impl Cluster

fn new(cluster_id: u64) -> Cluster

fn bootstrap(&mut self, store: Store, region: Region)

fn set_bootstrap(&mut self, is_bootstraped: bool)

fn alloc_id(&self) -> Result<u64>

fn put_store(&mut self, store: Store) -> Result<()>

fn get_store(&self, store_id: u64) -> Result<Store>

fn get_all_stores(&self) -> Result<Vec<Store>>

fn get_region(&self, key: Vec<u8>) -> Option<Region>

fn get_region_by_id(&self, region_id: u64) -> Result<Option<Region>>

fn get_region_approximate_size(&self, region_id: u64) -> Option<u64>

fn get_region_approximate_keys(&self, region_id: u64) -> Option<u64>

fn get_region_last_report_ts(&self, region_id: u64) -> Option<UnixSecs>

fn get_region_last_report_term(&self, region_id: u64) -> Option<u64>

fn get_store_hotspots(&self, store_id: u64) -> Option<HashMap<u64, PeerStat>>

fn get_stores(&self) -> Vec<Store>

fn get_regions_number(&self) -> usize

fn add_region(&mut self, region: &Region)

fn remove_region(&mut self, region: &Region)

fn get_overlap(&self, start_key: Vec<u8>, end_key: Vec<u8>) -> Vec<Region>

fn check_put_region(&mut self, region: Region) -> Result<Vec<Region>>

fn handle_heartbeat(
    &mut self,
    region: Region,
    leader: Peer
) -> Result<RegionHeartbeatResponse>

fn handle_heartbeat_max_peer_count(
    &mut self,
    region: &Region,
    leader: &Peer
) -> Option<Operator>

fn poll_heartbeat_responses_for(
    &mut self,
    store_id: u64
) -> Vec<RegionHeartbeatResponse>

fn poll_heartbeat_responses(
    &mut self,
    region: Region,
    leader: Peer
) -> Option<RegionHeartbeatResponse>

fn region_heartbeat(
    &mut self,
    term: u64,
    region: Region,
    leader: Peer,
    region_stat: RegionStat,
    replication_status: Option<RegionReplicationStatus>
) -> Result<RegionHeartbeatResponse>

fn set_gc_safe_point(&mut self, safe_point: u64)

fn get_gc_safe_point(&self) -> u64