org.tikv.common

Class KVMockServer

java.lang.Object

org.tikv.kvproto.TikvGrpc.TikvImplBase

org.tikv.common.KVMockServer

All Implemented Interfaces:

io.grpc.BindableService, TikvGrpc.AsyncService

public class KVMockServer
extends TikvGrpc.TikvImplBase

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KVMockServer.State

Field Summary

Fields

Modifier and Type	Field and Description
static int	ABORT
static int	KEY_NOT_IN_REGION
static int	NOT_LEADER
static int	RAFT_ENTRY_TOO_LARGE
static int	REGION_NOT_FOUND
static int	RETRY
static int	SERVER_IS_BUSY
static int	STALE_COMMAND
static int	STALE_EPOCH
static int	STORE_NOT_MATCH

Constructor Summary

Constructors

Constructor and Description
KVMockServer()

Method Summary

Modifier and Type	Method and Description
void	clearAllMap()
void	coprocessor(Coprocessor.Request requestWrap, io.grpc.stub.StreamObserver<Coprocessor.Response> responseObserver)
int	getPort()
boolean	hasLock(ByteString key)
void	kvBatchGet(Kvrpcpb.BatchGetRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.BatchGetResponse> responseObserver)
void	kvCheckTxnStatus(Kvrpcpb.CheckTxnStatusRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.CheckTxnStatusResponse> responseObserver)
void	kvGet(Kvrpcpb.GetRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.GetResponse> responseObserver)
void	kvResolveLock(Kvrpcpb.ResolveLockRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.ResolveLockResponse> responseObserver)
void	kvScan(Kvrpcpb.ScanRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.ScanResponse> responseObserver)
void	put(ByteString key, ByteString value)
void	put(String key, ByteString data)
void	put(String key, String value)
void	putError(String key, Supplier<Errorpb.Error.Builder> builder)
void	putTxnStatus(Long startTs, Long commitTs)
void	putTxnStatus(Long startTs, Long commitTs, ByteString key)
void	putWithLock(ByteString key, ByteString value, ByteString primaryKey, Long startTs, Long ttl)
void	rawDelete(Kvrpcpb.RawDeleteRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.RawDeleteResponse> responseObserver)
void	rawGet(Kvrpcpb.RawGetRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.RawGetResponse> responseObserver)
void	rawPut(Kvrpcpb.RawPutRequest request, io.grpc.stub.StreamObserver<Kvrpcpb.RawPutResponse> responseObserver)
void	remove(ByteString key)
void	removeError(String key)
void	removeLock(ByteString key)
void	setRegion(TiRegion region)
void	setState(KVMockServer.State state)
int	start(TiRegion region)
void	start(TiRegion region, int port)
void	stop()

Methods inherited from class org.tikv.kvproto.TikvGrpc.TikvImplBase

bindService

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tikv.kvproto.TikvGrpc.AsyncService

batchCommands, batchCoprocessor, batchRaft, cancelMPPTask, checkLeader, checkLockObserver, coprocessorStream, dispatchMPPTask, establishMPPConnection, getLockWaitInfo, getStoreSafeTS, isAlive, kvBatchRollback, kvCheckSecondaryLocks, kvCleanup, kvCommit, kvDeleteRange, kvGC, kvImport, kvPessimisticLock, kVPessimisticRollback, kvPrewrite, kvScanLock, kvTxnHeartBeat, mvccGetByKey, mvccGetByStartTs, physicalScanLock, raft, rawBatchDelete, rawBatchGet, rawBatchPut, rawBatchScan, rawChecksum, rawCompareAndSwap, rawCoprocessor, rawDeleteRange, rawGetKeyTTL, rawScan, readIndex, registerLockObserver, removeLockObserver, snapshot, splitRegion, unsafeDestroyRange

Field Detail

ABORT

public static final int ABORT

See Also:

Constant Field Values

RETRY

public static final int RETRY

See Also:

Constant Field Values

NOT_LEADER

public static final int NOT_LEADER

See Also:

Constant Field Values

REGION_NOT_FOUND

public static final int REGION_NOT_FOUND

See Also:

Constant Field Values

KEY_NOT_IN_REGION

public static final int KEY_NOT_IN_REGION

See Also:

Constant Field Values

STALE_EPOCH

public static final int STALE_EPOCH

See Also:

Constant Field Values

SERVER_IS_BUSY

public static final int SERVER_IS_BUSY

See Also:

Constant Field Values

STALE_COMMAND

public static final int STALE_COMMAND

See Also:

Constant Field Values

STORE_NOT_MATCH

public static final int STORE_NOT_MATCH

See Also:

Constant Field Values

RAFT_ENTRY_TOO_LARGE

public static final int RAFT_ENTRY_TOO_LARGE

See Also:

Constant Field Values

Constructor Detail

KVMockServer

public KVMockServer()

Method Detail

setState

public void setState(KVMockServer.State state)

getPort

public int getPort()

setRegion

public void setRegion(TiRegion region)

put

public void put(ByteString key,
                ByteString value)

remove

public void remove(ByteString key)

put

public void put(String key,
                String value)

put

public void put(String key,
                ByteString data)

putError

public void putError(String key,
                     Supplier<Errorpb.Error.Builder> builder)

removeError

public void removeError(String key)

putWithLock

public void putWithLock(ByteString key,
                        ByteString value,
                        ByteString primaryKey,
                        Long startTs,
                        Long ttl)

removeLock

public void removeLock(ByteString key)

hasLock

public boolean hasLock(ByteString key)

putTxnStatus

public void putTxnStatus(Long startTs,
                         Long commitTs,
                         ByteString key)

putTxnStatus

public void putTxnStatus(Long startTs,
                         Long commitTs)

clearAllMap

public void clearAllMap()

rawGet

public void rawGet(Kvrpcpb.RawGetRequest request,
                   io.grpc.stub.StreamObserver<Kvrpcpb.RawGetResponse> responseObserver)

rawPut

public void rawPut(Kvrpcpb.RawPutRequest request,
                   io.grpc.stub.StreamObserver<Kvrpcpb.RawPutResponse> responseObserver)

rawDelete

public void rawDelete(Kvrpcpb.RawDeleteRequest request,
                      io.grpc.stub.StreamObserver<Kvrpcpb.RawDeleteResponse> responseObserver)

kvGet

public void kvGet(Kvrpcpb.GetRequest request,
                  io.grpc.stub.StreamObserver<Kvrpcpb.GetResponse> responseObserver)

kvScan

public void kvScan(Kvrpcpb.ScanRequest request,
                   io.grpc.stub.StreamObserver<Kvrpcpb.ScanResponse> responseObserver)

kvBatchGet

public void kvBatchGet(Kvrpcpb.BatchGetRequest request,
                       io.grpc.stub.StreamObserver<Kvrpcpb.BatchGetResponse> responseObserver)

kvCheckTxnStatus

public void kvCheckTxnStatus(Kvrpcpb.CheckTxnStatusRequest request,
                             io.grpc.stub.StreamObserver<Kvrpcpb.CheckTxnStatusResponse> responseObserver)

kvResolveLock

public void kvResolveLock(Kvrpcpb.ResolveLockRequest request,
                          io.grpc.stub.StreamObserver<Kvrpcpb.ResolveLockResponse> responseObserver)

coprocessor

public void coprocessor(Coprocessor.Request requestWrap,
                        io.grpc.stub.StreamObserver<Coprocessor.Response> responseObserver)

start

public int start(TiRegion region)
          throws IOException

Throws:

IOException

start

public void start(TiRegion region,
                  int port)
           throws IOException

Throws:

IOException

stop

public void stop()