Struct test_raftstore::server::ServerCluster

pub struct ServerCluster {
    metas: HashMap<u64, ServerMeta>,
    addrs: AddressMap,
    pub storages: HashMap<u64, SimulateEngine>,
    pub region_info_accessors: HashMap<u64, RegionInfoAccessor>,
    pub importers: HashMap<u64, Arc<SSTImporter>>,
    pub pending_services: HashMap<u64, Vec<Box<dyn Fn() -> Service>>>,
    pub coprocessor_hooks: HashMap<u64, Vec<Box<dyn Fn(&mut CoprocessorHost<RocksEngine>)>>>,
    pub security_mgr: Arc<SecurityManager>,
    pub txn_extra_schedulers: HashMap<u64, Arc<dyn TxnExtraScheduler>>,
    snap_paths: HashMap<u64, TempDir>,
    snap_mgrs: HashMap<u64, SnapManager>,
    pd_client: Arc<TestPdClient>,
    raft_client: RaftClient<AddressMap, RaftStoreBlackHole, RocksEngine>,
    concurrency_managers: HashMap<u64, ConcurrencyManager>,
    env: Arc<Environment>,
}

Fields

metas: HashMap<u64, ServerMeta>

addrs: AddressMap

storages: HashMap<u64, SimulateEngine>

region_info_accessors: HashMap<u64, RegionInfoAccessor>

importers: HashMap<u64, Arc<SSTImporter>>

pending_services: HashMap<u64, Vec<Box<dyn Fn() -> Service>>>

coprocessor_hooks: HashMap<u64, Vec<Box<dyn Fn(&mut CoprocessorHost<RocksEngine>)>>>

security_mgr: Arc<SecurityManager>

txn_extra_schedulers: HashMap<u64, Arc<dyn TxnExtraScheduler>>

snap_paths: HashMap<u64, TempDir>

snap_mgrs: HashMap<u64, SnapManager>

pd_client: Arc<TestPdClient>

raft_client: RaftClient<AddressMap, RaftStoreBlackHole, RocksEngine>

concurrency_managers: HashMap<u64, ConcurrencyManager>

env: Arc<Environment>

Implementations

impl ServerCluster

pub fn new(pd_client: Arc<TestPdClient>) -> ServerCluster

pub fn get_addr(&self, node_id: u64) -> String

pub fn get_apply_router(&self, node_id: u64) -> ApplyRouter<RocksEngine>

pub fn get_server_router(
    &self,
    node_id: u64
) -> SimulateTransport<ServerRaftStoreRouter<RocksEngine, RocksEngine>>

pub fn get_gc_worker(
    &self,
    node_id: u64
) -> &GcWorker<RaftKv<RocksEngine, SimulateTransport<ServerRaftStoreRouter<RocksEngine, RocksEngine>>>, SimulateTransport<ServerRaftStoreRouter<RocksEngine, RocksEngine>>>

To trigger GC manually.

pub fn get_concurrency_manager(&self, node_id: u64) -> ConcurrencyManager

pub fn start_resolved_ts_worker(&mut self)

Trait Implementations

impl Simulator for ServerCluster

fn run_node(
    &mut self,
    node_id: u64,
    cfg: TiKvConfig,
    engines: Engines<RocksEngine, RocksEngine>,
    store_meta: Arc<Mutex<StoreMeta>>,
    key_manager: Option<Arc<DataKeyManager>>,
    router: RaftRouter<RocksEngine, RocksEngine>,
    system: RaftBatchSystem<RocksEngine, RocksEngine>
) -> ServerResult<u64>

fn get_snap_dir(&self, node_id: u64) -> String

fn get_snap_mgr(&self, node_id: u64) -> &SnapManager

fn stop_node(&mut self, node_id: u64)

fn get_node_ids(&self) -> HashSet<u64>

fn async_command_on_node(
    &self,
    node_id: u64,
    request: RaftCmdRequest,
    cb: Callback<RocksSnapshot>
) -> Result<()>

fn async_read(
    &self,
    node_id: u64,
    batch_id: Option<ThreadReadId>,
    request: RaftCmdRequest,
    cb: Callback<RocksSnapshot>
)

fn send_raft_msg(&mut self, raft_msg: RaftMessage) -> Result<()>

fn add_send_filter(&mut self, node_id: u64, filter: Box<dyn Filter>)

fn clear_send_filters(&mut self, node_id: u64)

fn add_recv_filter(&mut self, node_id: u64, filter: Box<dyn Filter>)

fn clear_recv_filters(&mut self, node_id: u64)

fn get_router(
    &self,
    node_id: u64
) -> Option<RaftRouter<RocksEngine, RocksEngine>>

fn call_command(
    &self,
    request: RaftCmdRequest,
    timeout: Duration
) -> Result<RaftCmdResponse>

fn read(
    &self,
    batch_id: Option<ThreadReadId>,
    request: RaftCmdRequest,
    timeout: Duration
) -> Result<RaftCmdResponse>

fn call_command_on_node(
    &self,
    node_id: u64,
    request: RaftCmdRequest,
    timeout: Duration
) -> Result<RaftCmdResponse>