org.tikv.kvproto

Class ImportKVGrpc

java.lang.Object

org.tikv.kvproto.ImportKVGrpc

@Generated(value="by gRPC proto compiler (version 1.60.0)",
           comments="Source: import_kvpb.proto")
public final class ImportKVGrpc
extends Object

 ImportKV provides a service to import key-value pairs to TiKV.
 In order to import key-value pairs to TiKV, the user should:
 1. Open an engine identified by an UUID.
 2. Open write streams to write key-value batches to the opened engine.
    Different streams/clients can write to the same engine concurrently.
 3. Close the engine after all write batches have been finished. An
    engine can only be closed when all write streams are closed. An
    engine can only be closed once, and it can not be opened again
    once it is closed.
 4. Import the data in the engine to the target cluster. Note that
    the import process is not atomic, it requires the data to be
    idempotent on retry. An engine can only be imported after it is
    closed. An engine can be imported multiple times, but can not be
    imported concurrently.
 5. Clean up the engine after it has been imported. Delete all data
    in the engine. An engine can not be cleaned up when it is
    writing or importing.
 

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ImportKVGrpc.AsyncService ImportKV provides a service to import key-value pairs to TiKV.
static class	ImportKVGrpc.ImportKVBlockingStub A stub to allow clients to do synchronous rpc calls to service ImportKV.
static class	ImportKVGrpc.ImportKVFutureStub A stub to allow clients to do ListenableFuture-style rpc calls to service ImportKV.
static class	ImportKVGrpc.ImportKVImplBase Base class for the server implementation of the service ImportKV.
static class	ImportKVGrpc.ImportKVStub A stub to allow clients to do asynchronous rpc calls to service ImportKV.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SERVICE_NAME

Method Summary

Modifier and Type	Method and Description
static io.grpc.ServerServiceDefinition	bindService(ImportKVGrpc.AsyncService service)
static io.grpc.MethodDescriptor<ImportKvpb.CleanupEngineRequest,ImportKvpb.CleanupEngineResponse>	getCleanupEngineMethod()
static io.grpc.MethodDescriptor<ImportKvpb.CloseEngineRequest,ImportKvpb.CloseEngineResponse>	getCloseEngineMethod()
static io.grpc.MethodDescriptor<ImportKvpb.CompactClusterRequest,ImportKvpb.CompactClusterResponse>	getCompactClusterMethod()
static io.grpc.MethodDescriptor<ImportKvpb.GetMetricsRequest,ImportKvpb.GetMetricsResponse>	getGetMetricsMethod()
static io.grpc.MethodDescriptor<ImportKvpb.GetVersionRequest,ImportKvpb.GetVersionResponse>	getGetVersionMethod()
static io.grpc.MethodDescriptor<ImportKvpb.ImportEngineRequest,ImportKvpb.ImportEngineResponse>	getImportEngineMethod()
static io.grpc.MethodDescriptor<ImportKvpb.OpenEngineRequest,ImportKvpb.OpenEngineResponse>	getOpenEngineMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static io.grpc.MethodDescriptor<ImportKvpb.SwitchModeRequest,ImportKvpb.SwitchModeResponse>	getSwitchModeMethod()
static io.grpc.MethodDescriptor<ImportKvpb.WriteEngineRequest,ImportKvpb.WriteEngineResponse>	getWriteEngineMethod()
static io.grpc.MethodDescriptor<ImportKvpb.WriteEngineV3Request,ImportKvpb.WriteEngineResponse>	getWriteEngineV3Method()
static ImportKVGrpc.ImportKVBlockingStub	newBlockingStub(io.grpc.Channel channel) Creates a new blocking-style stub that supports unary and streaming output calls on the service
static ImportKVGrpc.ImportKVFutureStub	newFutureStub(io.grpc.Channel channel) Creates a new ListenableFuture-style stub that supports unary calls on the service
static ImportKVGrpc.ImportKVStub	newStub(io.grpc.Channel channel) Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

getSwitchModeMethod

public static io.grpc.MethodDescriptor<ImportKvpb.SwitchModeRequest,ImportKvpb.SwitchModeResponse> getSwitchModeMethod()

getOpenEngineMethod

public static io.grpc.MethodDescriptor<ImportKvpb.OpenEngineRequest,ImportKvpb.OpenEngineResponse> getOpenEngineMethod()

getWriteEngineMethod

public static io.grpc.MethodDescriptor<ImportKvpb.WriteEngineRequest,ImportKvpb.WriteEngineResponse> getWriteEngineMethod()

getWriteEngineV3Method

public static io.grpc.MethodDescriptor<ImportKvpb.WriteEngineV3Request,ImportKvpb.WriteEngineResponse> getWriteEngineV3Method()

getCloseEngineMethod

public static io.grpc.MethodDescriptor<ImportKvpb.CloseEngineRequest,ImportKvpb.CloseEngineResponse> getCloseEngineMethod()

getImportEngineMethod

public static io.grpc.MethodDescriptor<ImportKvpb.ImportEngineRequest,ImportKvpb.ImportEngineResponse> getImportEngineMethod()

getCleanupEngineMethod

public static io.grpc.MethodDescriptor<ImportKvpb.CleanupEngineRequest,ImportKvpb.CleanupEngineResponse> getCleanupEngineMethod()

getCompactClusterMethod

public static io.grpc.MethodDescriptor<ImportKvpb.CompactClusterRequest,ImportKvpb.CompactClusterResponse> getCompactClusterMethod()

getGetVersionMethod

public static io.grpc.MethodDescriptor<ImportKvpb.GetVersionRequest,ImportKvpb.GetVersionResponse> getGetVersionMethod()

getGetMetricsMethod

public static io.grpc.MethodDescriptor<ImportKvpb.GetMetricsRequest,ImportKvpb.GetMetricsResponse> getGetMetricsMethod()

newStub

public static ImportKVGrpc.ImportKVStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingStub

public static ImportKVGrpc.ImportKVBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static ImportKVGrpc.ImportKVFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

bindService

public static final io.grpc.ServerServiceDefinition bindService(ImportKVGrpc.AsyncService service)

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()