Enum tikv::read_pool::ReadPoolHandle

[−] Show declaration

pub enum ReadPoolHandle {
    FuturePools {
        read_pool_high: FuturePool,
        read_pool_normal: FuturePool,
        read_pool_low: FuturePool,
    },
    Yatp {
        remote: Remote<TaskCell>,
        running_tasks: IntGauge,
        max_tasks: usize,
        pool_size: usize,
    },
}

Variants

FuturePools

[−] Show fields

Fields of FuturePools

read_pool_high: FuturePoolread_pool_normal: FuturePoolread_pool_low: FuturePool

Yatp

[−] Show fields

Fields of Yatp

remote: Remote<TaskCell>running_tasks: IntGaugemax_tasks: usizepool_size: usize

Implementations

impl ReadPoolHandle[−]

pub fn spawn<F>(
    &self,
    f: F,
    priority: CommandPri,
    task_id: u64
) -> Result<(), ReadPoolError> where
    F: Future<Output = ()> + Send + 'static, 

pub fn spawn_handle<F, T>(
    &self,
    f: F,
    priority: CommandPri,
    task_id: u64
) -> impl Future<Output = Result<T, ReadPoolError>> where
    F: Future<Output = T> + Send + 'static,
    T: Send + 'static, 

pub fn get_normal_pool_size(&self) -> usize

pub fn get_queue_size_per_worker(&self) -> usize

Trait Implementations

impl Clone for ReadPoolHandle[+]

[+] Show hidden undocumented items

fn clone(&self) -> ReadPoolHandle[−]

Returns a copy of the value.

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

Performs copy-assignment from source.