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.