Struct tikv::server::service::debug::Service

pub struct Service<ER: RaftEngine, T: RaftStoreRouter<RocksEngine>> {
    pool: Handle,
    debugger: Debugger<ER>,
    raft_router: T,
}

Service handles the RPC messages for the Debug service.

Fields

pool: Handle

debugger: Debugger<ER>

raft_router: T

Implementations

impl<ER: RaftEngine, T: RaftStoreRouter<RocksEngine>> Service<ER, T>

pub fn new(
    engines: Engines<RocksEngine, ER>,
    pool: Handle,
    raft_router: T,
    cfg_controller: ConfigController
) -> Service<ER, T>

Constructs a new Service with Engines, a RaftStoreRouter and a GcWorker.

fn handle_response<F, P>(
    &self,
    ctx: RpcContext<'_>,
    sink: UnarySink<P>,
    resp: F,
    tag: &'static str
) where
    P: Send + 'static,
    F: Future<Output = Result<P>> + Send + 'static, 

Trait Implementations

impl<ER: Clone + RaftEngine, T: Clone + RaftStoreRouter<RocksEngine>> Clone for Service<ER, T>

fn clone(&self) -> Service<ER, T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<ER: RaftEngine, T: RaftStoreRouter<RocksEngine> + 'static> Debug for Service<ER, T>

fn get(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetRequest,
    sink: UnarySink<GetResponse>
)

fn raft_log(
    &mut self,
    ctx: RpcContext<'_>,
    req: RaftLogRequest,
    sink: UnarySink<RaftLogResponse>
)

fn region_info(
    &mut self,
    ctx: RpcContext<'_>,
    req: RegionInfoRequest,
    sink: UnarySink<RegionInfoResponse>
)

fn region_size(
    &mut self,
    ctx: RpcContext<'_>,
    req: RegionSizeRequest,
    sink: UnarySink<RegionSizeResponse>
)

fn scan_mvcc(
    &mut self,
    _: RpcContext<'_>,
    req: ScanMvccRequest,
    sink: ServerStreamingSink<ScanMvccResponse>
)

fn compact(
    &mut self,
    ctx: RpcContext<'_>,
    req: CompactRequest,
    sink: UnarySink<CompactResponse>
)

fn inject_fail_point(
    &mut self,
    ctx: RpcContext<'_>,
    req: InjectFailPointRequest,
    sink: UnarySink<InjectFailPointResponse>
)

fn recover_fail_point(
    &mut self,
    ctx: RpcContext<'_>,
    req: RecoverFailPointRequest,
    sink: UnarySink<RecoverFailPointResponse>
)

fn list_fail_points(
    &mut self,
    ctx: RpcContext<'_>,
    _: ListFailPointsRequest,
    sink: UnarySink<ListFailPointsResponse>
)

fn get_metrics(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetMetricsRequest,
    sink: UnarySink<GetMetricsResponse>
)

fn check_region_consistency(
    &mut self,
    ctx: RpcContext<'_>,
    req: RegionConsistencyCheckRequest,
    sink: UnarySink<RegionConsistencyCheckResponse>
)

fn modify_tikv_config(
    &mut self,
    ctx: RpcContext<'_>,
    req: ModifyTikvConfigRequest,
    sink: UnarySink<ModifyTikvConfigResponse>
)

fn get_region_properties(
    &mut self,
    ctx: RpcContext<'_>,
    req: GetRegionPropertiesRequest,
    sink: UnarySink<GetRegionPropertiesResponse>
)

fn get_store_info(
    &mut self,
    ctx: RpcContext<'_>,
    _: GetStoreInfoRequest,
    sink: UnarySink<GetStoreInfoResponse>
)

fn get_cluster_info(
    &mut self,
    ctx: RpcContext<'_>,
    _: GetClusterInfoRequest,
    sink: UnarySink<GetClusterInfoResponse>
)