Struct tikv::storage::mvcc::reader::scanner::forward::ForwardScanner [−][src]
Fields
cfg: ScannerConfig<S>cursors: Cursors<S>is_started: boolIs iteration started
statistics: Statisticsscan_policy: Pmet_newer_ts_data: NewerTsCheckStateImplementations
impl<S: Snapshot, P: ScanPolicy<S>> ForwardScanner<S, P>[src]
pub fn new(
cfg: ScannerConfig<S>,
lock_cursor: Cursor<S::Iter>,
write_cursor: Cursor<S::Iter>,
default_cursor: Option<Cursor<S::Iter>>,
scan_policy: P
) -> ForwardScanner<S, P>[src]
cfg: ScannerConfig<S>,
lock_cursor: Cursor<S::Iter>,
write_cursor: Cursor<S::Iter>,
default_cursor: Option<Cursor<S::Iter>>,
scan_policy: P
) -> ForwardScanner<S, P>
pub fn take_statistics(&mut self) -> Statistics[src]
Take out and reset the statistics collected so far.
pub fn met_newer_ts_data(&self) -> NewerTsCheckState[src]
Whether we met newer ts data.
The result is always Unknown if check_has_newer_ts_data is not set.
pub fn read_next(&mut self) -> Result<Option<P::Output>>[src]
Get the next key-value pair, in forward order.
fn move_write_cursor_to_ts(&mut self, user_key: &Key) -> Result<bool>[src]
Try to move the write cursor to the self.cfg.ts version of the given key.
Because it is possible that the cursor is moved to the next user key or
the end of key space, the method returns whether the write cursor still
points to the given user key.
Trait Implementations
impl<S, P> TxnEntryScanner for ForwardScanner<S, P> where
S: Snapshot,
P: ScanPolicy<S, Output = TxnEntry> + Send, [src]
S: Snapshot,
P: ScanPolicy<S, Output = TxnEntry> + Send,
fn next_entry(&mut self) -> TxnResult<Option<TxnEntry>>[src]
fn take_statistics(&mut self) -> Statistics[src]
fn scan_entries(&mut self, batch: &mut EntryBatch) -> Result<()>[src]
Auto Trait Implementations
impl<S, P> !RefUnwindSafe for ForwardScanner<S, P>
impl<S, P> Send for ForwardScanner<S, P> where
P: Send,
P: Send,
impl<S, P> !Sync for ForwardScanner<S, P>
impl<S, P> Unpin for ForwardScanner<S, P> where
P: Unpin,
S: Unpin,
<S as Snapshot>::Iter: Unpin,
P: Unpin,
S: Unpin,
<S as Snapshot>::Iter: Unpin,
impl<S, P> UnwindSafe for ForwardScanner<S, P> where
P: UnwindSafe,
S: UnwindSafe,
<S as Snapshot>::Iter: UnwindSafe,
P: UnwindSafe,
S: UnwindSafe,
<S as Snapshot>::Iter: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<V, W> ConvertFrom<W> for V where
W: ConvertTo<V>, [src]
W: ConvertTo<V>,
pub fn convert_from(ctx: &mut EvalContext, from: W) -> Result<V, Error>[src]
impl<T> From<T> for T[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
impl<T> Pointable for T[src]
pub const ALIGN: usize[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T[src]
pub unsafe fn drop(ptr: usize)[src]
impl<T> Pointable for T[src]
pub const ALIGN: usize[src]
type Init = T
The type for initializers.
pub unsafe fn init(init: <T as Pointable>::Init) -> usize[src]
pub unsafe fn deref<'a>(ptr: usize) -> &'a T[src]
pub unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T[src]
pub unsafe fn drop(ptr: usize)[src]
impl<T> Same<T> for T[src]
type Output = T
Should always be Self
impl<T> Sealed<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> SendSyncUnwindSafe for T where
T: Send + Sync + UnwindSafe + ?Sized, [src]
T: Send + Sync + UnwindSafe + ?Sized,
impl<T, U> TryFrom<U> for T where
U: Into<T>, [src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>, [src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>, [src]
V: MultiLane<T>,