Struct resolved_ts::ScannerPool

[+] Show declaration

pub struct ScannerPool<T, E> {
    workers: Arc<Runtime>,
    raft_router: T,
    _phantom: PhantomData<E>,
}

Fields

workers: Arc<Runtime>

raft_router: T

_phantom: PhantomData<E>

Implementations

impl<T: 'static + RaftStoreRouter<E>, E: KvEngine> ScannerPool<T, E>[−]

pub fn new(count: usize, raft_router: T) -> Self

pub fn spawn_task(&self, task: ScanTask)

async fn get_snapshot(
    task: &mut ScanTask,
    raft_router: T
) -> Result<RegionSnapshot<E::Snapshot>>

fn scan_locks<S: Snapshot>(
    reader: &mut MvccReader<S>,
    start: Option<&Key>,
    _checkpoint_ts: TimeStamp
) -> Result<(Vec<(Key, Lock)>, bool)>

fn scan_delta<S: Snapshot>(
    scanner: &mut DeltaScanner<S>
) -> Result<(Vec<TxnEntry>, bool)>

Trait Implementations

impl<T: Clone, E: Clone> Clone for ScannerPool<T, E>[+]

[+] Show hidden undocumented items

fn clone(&self) -> ScannerPool<T, E>[−]

Returns a copy of the value.

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

Performs copy-assignment from source.