@Generated(value="by gRPC proto compiler (version 1.60.0)", comments="Source: import_sstpb.proto") public final class ImportSSTGrpc extends Object
ImportSST provides a service to import a generated SST file to a region in TiKV. In order to import an SST file to a region, the user should: 1. Retrieve the meta of the region according to the SST file's range. 2. Upload the SST file to the servers where the region's peers locate in. 3. Issue an ingest request to the region's leader with the SST file's metadata. It's the user's responsibility to make sure that the SST file is uploaded to the servers where the region's peers locate in, before issue the ingest request to the region's leader. However, the region can be scheduled (so the location of the region's peers will be changed) or split/merged (so the range of the region will be changed), after the SST file is uploaded, but before the SST file is ingested. So, the region's epoch is provided in the SST file's metadata, to guarantee that the region's epoch must be the same between the SST file is uploaded and ingested later.
Modifier and Type | Class and Description |
---|---|
static interface |
ImportSSTGrpc.AsyncService
ImportSST provides a service to import a generated SST file to a region in TiKV.
|
static class |
ImportSSTGrpc.ImportSSTBlockingStub
A stub to allow clients to do synchronous rpc calls to service ImportSST.
|
static class |
ImportSSTGrpc.ImportSSTFutureStub
A stub to allow clients to do ListenableFuture-style rpc calls to service ImportSST.
|
static class |
ImportSSTGrpc.ImportSSTImplBase
Base class for the server implementation of the service ImportSST.
|
static class |
ImportSSTGrpc.ImportSSTStub
A stub to allow clients to do asynchronous rpc calls to service ImportSST.
|
Modifier and Type | Field and Description |
---|---|
static String |
SERVICE_NAME |
public static final String SERVICE_NAME
public static io.grpc.MethodDescriptor<ImportSstpb.SwitchModeRequest,ImportSstpb.SwitchModeResponse> getSwitchModeMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.UploadRequest,ImportSstpb.UploadResponse> getUploadMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.IngestRequest,ImportSstpb.IngestResponse> getIngestMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.CompactRequest,ImportSstpb.CompactResponse> getCompactMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.SetDownloadSpeedLimitRequest,ImportSstpb.SetDownloadSpeedLimitResponse> getSetDownloadSpeedLimitMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.DownloadRequest,ImportSstpb.DownloadResponse> getDownloadMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.WriteRequest,ImportSstpb.WriteResponse> getWriteMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.RawWriteRequest,ImportSstpb.RawWriteResponse> getRawWriteMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.MultiIngestRequest,ImportSstpb.IngestResponse> getMultiIngestMethod()
public static io.grpc.MethodDescriptor<ImportSstpb.DuplicateDetectRequest,ImportSstpb.DuplicateDetectResponse> getDuplicateDetectMethod()
public static ImportSSTGrpc.ImportSSTStub newStub(io.grpc.Channel channel)
public static ImportSSTGrpc.ImportSSTBlockingStub newBlockingStub(io.grpc.Channel channel)
public static ImportSSTGrpc.ImportSSTFutureStub newFutureStub(io.grpc.Channel channel)
public static final io.grpc.ServerServiceDefinition bindService(ImportSSTGrpc.AsyncService service)
public static io.grpc.ServiceDescriptor getServiceDescriptor()
Copyright © 2024 PingCAP. All rights reserved.