Struct tikv::coprocessor::dag::BatchDAGHandler

[+] Show declaration

pub struct BatchDAGHandler {
    runner: BatchExecutorsRunner<Statistics>,
    data_version: Option<u64>,
}

Fields

runner: BatchExecutorsRunner<Statistics>

data_version: Option<u64>

Implementations

impl BatchDAGHandler[−]

pub fn new<S: Store + 'static>(
    req: DagRequest,
    ranges: Vec<KeyRange>,
    store: S,
    data_version: Option<u64>,
    deadline: Deadline,
    is_cache_enabled: bool,
    streaming_batch_limit: usize,
    is_streaming: bool
) -> Result<Self>

Trait Implementations

impl RequestHandler for BatchDAGHandler[+]

[+] Show hidden undocumented items

fn handle_request<'life0, 'async_trait>(
    &'life0 mut self
) -> Pin<Box<dyn Future<Output = Result<Response>> + Send + 'async_trait>> where
    'life0: 'async_trait,
    Self: 'async_trait, [−]

Processes current request and produces a response.

fn handle_streaming_request(&mut self) -> Result<(Option<Response>, bool)>[−]

Processes current request and produces streaming responses.

fn collect_scan_statistics(&mut self, dest: &mut Statistics)[−]

Collects scan statistics generated in this request handler so far.

fn into_boxed(self) -> Box<dyn RequestHandler> where
    Self: 'static + Sized,