Struct test_raftstore::NodeCluster

pub struct NodeCluster {
    trans: ChannelTransport,
    pd_client: Arc<TestPdClient>,
    nodes: HashMap<u64, Node<TestPdClient, RocksEngine>>,
    snap_mgrs: HashMap<u64, SnapManager>,
    simulate_trans: HashMap<u64, SimulateTransport<ChannelTransport>>,
    concurrency_managers: HashMap<u64, ConcurrencyManager>,
    post_create_coprocessor_host: Option<Box<dyn Fn(u64, &mut CoprocessorHost<RocksEngine>)>>,
}

Fields

trans: ChannelTransport

pd_client: Arc<TestPdClient>

nodes: HashMap<u64, Node<TestPdClient, RocksEngine>>

snap_mgrs: HashMap<u64, SnapManager>

simulate_trans: HashMap<u64, SimulateTransport<ChannelTransport>>

concurrency_managers: HashMap<u64, ConcurrencyManager>

post_create_coprocessor_host: Option<Box<dyn Fn(u64, &mut CoprocessorHost<RocksEngine>)>>

Implementations

impl NodeCluster

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

impl NodeCluster

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

pub fn post_create_coprocessor_host(
    &mut self,
    op: Box<dyn Fn(u64, &mut CoprocessorHost<RocksEngine>)>
)

pub fn get_node(
    &mut self,
    node_id: u64
) -> Option<&mut Node<TestPdClient, RocksEngine>>

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

Trait Implementations

impl Simulator for NodeCluster

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