Struct tikv::storage::mvcc::reader::scanner::forward::DeltaEntryPolicy[][src]

pub struct DeltaEntryPolicy {
    from_ts: TimeStamp,
    extra_op: ExtraOp,
}

The ScanPolicy for outputting TxnEntry for every locks or commits in specified ts range.

The ForwardScanner with this policy scans all entries whose commit_tss (or locks’ start_tss) in range (from_ts, cfg.ts].

Fields

from_ts: TimeStampextra_op: ExtraOp

Implementations

impl DeltaEntryPolicy[src]

pub fn new(from_ts: TimeStamp, extra_op: ExtraOp) -> Self[src]

Trait Implementations

impl<S: Snapshot> ScanPolicy<S> for DeltaEntryPolicy[src]

type Output = TxnEntry

The type that the scanner outputs.

Auto Trait Implementations

impl RefUnwindSafe for DeltaEntryPolicy

impl Send for DeltaEntryPolicy

impl Sync for DeltaEntryPolicy

impl Unpin for DeltaEntryPolicy

impl UnwindSafe for DeltaEntryPolicy

Blanket Implementations

impl<T> Any for T where
    T: 'static + ?Sized
[src]

impl<T> Borrow<T> for T where
    T: ?Sized
[src]

impl<T> BorrowMut<T> for T where
    T: ?Sized
[src]

impl<V, W> ConvertFrom<W> for V where
    W: ConvertTo<V>, 
[src]

impl<T> From<T> for T[src]

impl<T> Instrument for T[src]

impl<T, U> Into<U> for T where
    U: From<T>, 
[src]

impl<T> Pointable for T[src]

type Init = T

The type for initializers.

impl<T> Pointable for T[src]

type Init = T

The type for initializers.

impl<T> Same<T> for T[src]

type Output = T

Should always be Self

impl<T> Sealed<T> for T where
    T: ?Sized
[src]

impl<T> SendSyncUnwindSafe for T where
    T: Send + Sync + UnwindSafe + ?Sized
[src]

impl<T, U> TryFrom<U> for T where
    U: Into<T>, 
[src]

type Error = Infallible

The type returned in the event of a conversion error.

impl<T, U> TryInto<U> for T where
    U: TryFrom<T>, 
[src]

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.

impl<V, T> VZip<V> for T where
    V: MultiLane<T>, 
[src]