Struct tikv::server::server::Server

pub struct Server<T: RaftStoreRouter<RocksEngine> + 'static, S: StoreAddrResolver + 'static> {
    env: Arc<Environment>,
    builder_or_server: Option<Either<ServerBuilder, GrpcServer>>,
    local_addr: SocketAddr,
    trans: ServerTransport<T, S, RocksEngine>,
    raft_router: T,
    snap_mgr: SnapManager,
    snap_worker: LazyWorker<SnapTask>,
    stats_pool: Option<Runtime>,
    grpc_thread_load: Arc<ThreadLoad>,
    yatp_read_pool: Option<ReadPool>,
    debug_thread_pool: Arc<Runtime>,
    health_service: HealthService,
    timer: Handle,
}

The TiKV server

It hosts various internal components, including gRPC, the raftstore router and a snapshot worker.

Fields

env: Arc<Environment>

builder_or_server: Option<Either<ServerBuilder, GrpcServer>>

A GrpcServer builder or a GrpcServer.

If the listening port is configured, the server will be started lazily.

local_addr: SocketAddr

trans: ServerTransport<T, S, RocksEngine>

raft_router: T

snap_mgr: SnapManager

snap_worker: LazyWorker<SnapTask>

stats_pool: Option<Runtime>

grpc_thread_load: Arc<ThreadLoad>

yatp_read_pool: Option<ReadPool>

debug_thread_pool: Arc<Runtime>

health_service: HealthService

timer: Handle

Implementations

impl<T: RaftStoreRouter<RocksEngine> + Unpin, S: StoreAddrResolver + 'static> Server<T, S>

pub fn new<E: Engine, L: LockManager>(
    store_id: u64,
    cfg: &Arc<VersionTrack<Config>>,
    security_mgr: &Arc<SecurityManager>,
    storage: Storage<E, L>,
    copr: Endpoint<E>,
    copr_v2: Endpoint,
    raft_router: T,
    resolver: S,
    snap_mgr: SnapManager,
    gc_worker: GcWorker<E, T>,
    env: Arc<Environment>,
    yatp_read_pool: Option<ReadPool>,
    debug_thread_pool: Arc<Runtime>
) -> Result<Self>

pub fn get_debug_thread_pool(&self) -> &RuntimeHandle

pub fn get_snap_worker_scheduler(&self) -> Scheduler<SnapTask>

pub fn transport(&self) -> ServerTransport<T, S, RocksEngine>

pub fn env(&self) -> Arc<Environment>

pub fn register_service(&mut self, svc: Service) -> Option<Service>

Register a gRPC service. Register after starting, it fails and returns the service.

pub fn build_and_bind(&mut self) -> Result<SocketAddr>

Build gRPC server and bind to address.

pub fn start(
    &mut self,
    cfg: Arc<VersionTrack<Config>>,
    security_mgr: Arc<SecurityManager>
) -> Result<()>

Starts the TiKV server. Notice: Make sure call build_and_bind first.

pub fn stop(&mut self) -> Result<()>

Stops the TiKV server.

pub fn listening_addr(&self) -> SocketAddr