Struct tikv::server::raftkv::RaftKv

pub struct RaftKv<E, S> where
    E: KvEngine,
    S: RaftStoreRouter<E> + LocalReadRouter<E> + 'static,  {
    router: S,
    engine: E,
    txn_extra_scheduler: Option<Arc<dyn TxnExtraScheduler>>,
}

RaftKv is a storage engine base on RaftStore.

Fields

router: S

engine: E

txn_extra_scheduler: Option<Arc<dyn TxnExtraScheduler>>

Implementations

impl<E, S> RaftKv<E, S> where
    E: KvEngine,
    S: RaftStoreRouter<E> + LocalReadRouter<E> + 'static, 

pub fn new(router: S, engine: E) -> RaftKv<E, S>

Create a RaftKv using specified configuration.

pub fn set_txn_extra_scheduler(
    &mut self,
    txn_extra_scheduler: Arc<dyn TxnExtraScheduler>
)

fn new_request_header(&self, ctx: &Context) -> RaftRequestHeader

fn exec_snapshot(
    &self,
    ctx: SnapContext<'_>,
    req: Request,
    cb: Callback<CmdRes<E::Snapshot>>
) -> Result<()>

fn exec_write_requests(
    &self,
    ctx: &Context,
    batch: WriteData,
    write_cb: Callback<CmdRes<E::Snapshot>>,
    proposed_cb: Option<ExtCallback>,
    committed_cb: Option<ExtCallback>
) -> Result<()>

Trait Implementations

impl<E: Clone, S: Clone> Clone for RaftKv<E, S> where
    E: KvEngine,
    S: RaftStoreRouter<E> + LocalReadRouter<E> + 'static, 

fn clone(&self) -> RaftKv<E, S>

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E, S> Debug for RaftKv<E, S> where
    E: KvEngine,
    S: RaftStoreRouter<E> + LocalReadRouter<E> + 'static, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E, S> Display for RaftKv<E, S> where
    E: KvEngine,
    S: RaftStoreRouter<E> + LocalReadRouter<E> + 'static, 

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<E, S> Engine for RaftKv<E, S> where
    E: KvEngine,
    S: RaftStoreRouter<E> + LocalReadRouter<E> + 'static, 

type Snap = RegionSnapshot<E::Snapshot>

type Local = E

fn kv_engine(&self) -> E

Local storage engine.

fn snapshot_on_kv_engine(
    &self,
    start_key: &[u8],
    end_key: &[u8]
) -> Result<Self::Snap>

fn modify_on_kv_engine(&self, modifies: Vec<Modify>) -> Result<()>

Write modifications into internal local engine directly.

fn async_write(
    &self,
    ctx: &Context,
    batch: WriteData,
    write_cb: Callback<()>
) -> Result<()>

fn async_write_ext(
    &self,
    ctx: &Context,
    batch: WriteData,
    write_cb: Callback<()>,
    proposed_cb: Option<ExtCallback>,
    committed_cb: Option<ExtCallback>
) -> Result<()>

Writes data to the engine asynchronously with some extensions.

fn async_snapshot(
    &self,
    ctx: SnapContext<'_>,
    cb: Callback<Self::Snap>
) -> Result<()>

fn release_snapshot(&self)

fn get_mvcc_properties_cf(
    &self,
    cf: CfName,
    safe_point: TimeStamp,
    start: &[u8],
    end: &[u8]
) -> Option<MvccProperties>

pub fn write(&self, ctx: &Context, batch: WriteData) -> Result<(), Error>

pub fn snapshot(&self, ctx: SnapContext<'_>) -> Result<Self::Snap, Error>

pub fn put(
    &self,
    ctx: &Context,
    key: Key,
    value: Vec<u8, Global>
) -> Result<(), Error>

pub fn put_cf(
    &self,
    ctx: &Context,
    cf: &'static str,
    key: Key,
    value: Vec<u8, Global>
) -> Result<(), Error>

pub fn delete(&self, ctx: &Context, key: Key) -> Result<(), Error>

pub fn delete_cf(
    &self,
    ctx: &Context,
    cf: &'static str,
    key: Key
) -> Result<(), Error>