Function tikv::server::node::create_raft_storage [−][src]
pub fn create_raft_storage<S>(
engine: RaftKv<RocksEngine, S>,
cfg: &StorageConfig,
read_pool: ReadPoolHandle,
lock_mgr: LockManager,
concurrency_manager: ConcurrencyManager,
pipelined_pessimistic_lock: Arc<AtomicBool>
) -> Result<Storage<RaftKv<RocksEngine, S>, LockManager>> where
S: RaftStoreRouter<RocksEngine> + LocalReadRouter<RocksEngine> + 'static,
Creates a new storage engine which is backed by the Raft consensus protocol.