pub fn create_raft_storage<S>(
    engine: RaftKv<S>,
    cfg: &StorageConfig,
    read_pool: ReadPoolHandle,
    lock_mgr: LockManager,
    concurrency_manager: ConcurrencyManager,
    pipelined_pessimistic_lock: bool,
) -> Result<Storage<RaftKv<S>, LockManager>>
where
    S: RaftStoreRouter<RocksEngine> + LocalReadRouter<RocksEngine> + 'static,
{
    let store = Storage::from_engine(
        engine,
        cfg,
        read_pool,
        lock_mgr,
        concurrency_manager,
        pipelined_pessimistic_lock,
    )?;
    Ok(store)
}
/// Creates a new storage engine which is backed by the Raft consensus
/// protocol.
Creates a new storage engine which is backed by the Raft consensus
protocol.
Creates a new storage engine which is backed by the Raft consensus protocol .
pub fn create_raft_storage<S>(
    engine: RaftKv<S>,
    cfg: &StorageConfig,
    read_pool: ReadPoolHandle,
    lock_mgr: LockManager,
    concurrency_manager: ConcurrencyManager,
    pipelined_pessimistic_lock: bool,
) -> Result<Storage<RaftKv<S>, LockManager>>
where
    S: RaftStoreRouter<RocksEngine> + LocalReadRouter<RocksEngine> + 'static,
{
    let store = Storage::from_engine(
        engine,
        cfg,
        read_pool,
        lock_mgr,
        concurrency_manager,
        pipelined_pessimistic_lock,
    )?;
    Ok(store)
}
pub fn create_raft_storage < S > ( engine : RaftKv < S > , cfg : & StorageConfig , read_pool : ReadPoolHandle , lock_mgr : LockManager , concurrency_manager : ConcurrencyManager , pipelined_pessimistic_lock : bool , ) -> Result < Storage < RaftKv < S > , LockManager > > where S : RaftStoreRouter < RocksEngine > + LocalReadRouter < RocksEngine > + ' static , { let store = Storage :: from_engine ( engine , cfg , read_pool , lock_mgr , concurrency_manager , pipelined_pessimistic_lock , ) ? ; Ok ( store ) }
Creates a new storage engine which is backed by the Raft consensus
protocol.
Creates a new storage engine which is backed by the Raft consensus protocol .
engine
RaftKv<S>
cfg
&StorageConfig
read_pool
ReadPoolHandle
lock_mgr
LockManager
concurrency_manager
ConcurrencyManager
pipelined_pessimistic_lock
bool