Uses of Interface
org.tikv.common.util.BackOffer

Packages that use BackOffer

Package	Description
org.tikv.common
org.tikv.common.operation
org.tikv.common.operation.iterator
org.tikv.common.policy
org.tikv.common.region
org.tikv.common.util
org.tikv.txn

Uses of BackOffer in org.tikv.common

Methods in org.tikv.common with parameters of type BackOffer

Modifier and Type	Method and Description
List<Kvrpcpb.KvPair>	KVClient.batchGet(BackOffer backOffer, List<com.google.protobuf.ByteString> keys, long version) Get a set of key-value pair by keys from TiKV
protected <ReqT,RespT> void	AbstractGRPCClient.callAsyncWithRetry(BackOffer backOffer, io.grpc.MethodDescriptor<ReqT,RespT> method, Supplier<ReqT> requestFactory, io.grpc.stub.StreamObserver<RespT> responseObserver, ErrorHandler<RespT> handler)
<ReqT,RespT> StreamingResponse	AbstractGRPCClient.callServerStreamingWithRetry(BackOffer backOffer, io.grpc.MethodDescriptor<ReqT,RespT> method, Supplier<ReqT> requestFactory, ErrorHandler<StreamingResponse> handler)
<ReqT,RespT> RespT	AbstractGRPCClient.callWithRetry(BackOffer backOffer, io.grpc.MethodDescriptor<ReqT,RespT> method, Supplier<ReqT> requestFactory, ErrorHandler<RespT> handler)
protected boolean	AbstractGRPCClient.checkHealth(BackOffer backOffer, String addressStr, HostMapping hostMapping)
List<Metapb.Store>	ReadOnlyPDClient.getAllStores(BackOffer backOffer)
List<Metapb.Store>	PDClient.getAllStores(BackOffer backOffer)
Pair<Metapb.Region,Metapb.Peer>	ReadOnlyPDClient.getRegionByID(BackOffer backOffer, long id) Get Region by Region Id
Pair<Metapb.Region,Metapb.Peer>	PDClient.getRegionByID(BackOffer backOffer, long id)
Pair<Metapb.Region,Metapb.Peer>	ReadOnlyPDClient.getRegionByKey(BackOffer backOffer, com.google.protobuf.ByteString key) Get Region from PD by key specified
Pair<Metapb.Region,Metapb.Peer>	PDClient.getRegionByKey(BackOffer backOffer, com.google.protobuf.ByteString key)
Metapb.Store	ReadOnlyPDClient.getStore(BackOffer backOffer, long storeId) Get Store by StoreId
Metapb.Store	PDClient.getStore(BackOffer backOffer, long storeId)
TiTimestamp	ReadOnlyPDClient.getTimestamp(BackOffer backOffer) Get Timestamp from Placement Driver
TiTimestamp	PDClient.getTimestamp(BackOffer backOffer)
List<Pdpb.Region>	ReadOnlyPDClient.scanRegions(BackOffer backOffer, com.google.protobuf.ByteString startKey, com.google.protobuf.ByteString endKey, int limit)
List<Pdpb.Region>	PDClient.scanRegions(BackOffer backOffer, com.google.protobuf.ByteString startKey, com.google.protobuf.ByteString endKey, int limit)
Long	ReadOnlyPDClient.updateServiceGCSafePoint(String serviceId, long ttl, long safePoint, BackOffer backOffer) Update ServiceGCSafePoint
Long	PDClient.updateServiceGCSafePoint(String serviceId, long ttl, long safePoint, BackOffer backOffer)

Uses of BackOffer in org.tikv.common.operation

Methods in org.tikv.common.operation with parameters of type BackOffer

Modifier and Type	Method and Description
boolean	RegionErrorHandler.handleRegionError(BackOffer backOffer, Errorpb.Error error)
boolean	PDErrorHandler.handleRequestError(BackOffer backOffer, Exception e)
boolean	NoopHandler.handleRequestError(BackOffer backOffer, Exception e)
boolean	ErrorHandler.handleRequestError(BackOffer backOffer, Exception e) Handle the error received during a calling process before it could return a normal response.
boolean	KVErrorHandler.handleRequestError(BackOffer backOffer, Exception e)
boolean	RegionErrorHandler.handleRequestError(BackOffer backOffer, Exception e)
boolean	NoopHandler.handleResponseError(BackOffer backOffer, Object resp)
boolean	PDErrorHandler.handleResponseError(BackOffer backOffer, RespT resp)
boolean	ErrorHandler.handleResponseError(BackOffer backOffer, RespT resp) Handle the error received in the response after a calling process completes.
boolean	KVErrorHandler.handleResponseError(BackOffer backOffer, RespT resp)
boolean	RegionErrorHandler.handleResponseError(BackOffer backOffer, RespT resp)

Uses of BackOffer in org.tikv.common.operation.iterator

Constructors in org.tikv.common.operation.iterator with parameters of type BackOffer

Constructor and Description
RawScanIterator(TiConfiguration conf, RegionStoreClient.RegionStoreClientBuilder builder, com.google.protobuf.ByteString startKey, com.google.protobuf.ByteString endKey, int limit, boolean keyOnly, BackOffer scanBackOffer)

Uses of BackOffer in org.tikv.common.policy

Methods in org.tikv.common.policy with parameters of type BackOffer

Modifier and Type	Method and Description
RespT	RetryPolicy.callWithRetry(Callable<RespT> proc, String methodName, BackOffer backOffer)

Constructors in org.tikv.common.policy with parameters of type BackOffer

Constructor and Description
Builder(BackOffer backOffer)

Uses of BackOffer in org.tikv.common.region

Methods in org.tikv.common.region with parameters of type BackOffer

Modifier and Type	Method and Description
List<Kvrpcpb.KvPair>	RegionStoreClient.batchGet(BackOffer backOffer, List<com.google.protobuf.ByteString> keys, long version)
RegionStoreClient	RegionStoreClient.RegionStoreClientBuilder.build(com.google.protobuf.ByteString key, BackOffer backOffer)
RegionStoreClient	RegionStoreClient.RegionStoreClientBuilder.build(com.google.protobuf.ByteString key, TiStoreType storeType, BackOffer backOffer)
RegionStoreClient	RegionStoreClient.RegionStoreClientBuilder.build(TiRegion region, BackOffer backOffer)
void	RegionStoreClient.commit(BackOffer backOffer, Iterable<com.google.protobuf.ByteString> keys, long startTs, long commitTs) Commit batch keys
List<RangeSplitter.RegionTask>	RegionStoreClient.coprocess(BackOffer backOffer, DAGRequest req, List<Coprocessor.KeyRange> ranges, Queue<SelectResponse> responseQueue, long startTs) Execute and retrieve the response from TiKV server.
TiRegion	RegionManager.createRegion(Metapb.Region region, BackOffer backOffer)
com.google.protobuf.ByteString	RegionStoreClient.get(BackOffer backOffer, com.google.protobuf.ByteString key, long version) Fetch a value according to a key
TiRegion	RegionManager.getRegionByKey(com.google.protobuf.ByteString key, BackOffer backOffer)
TiRegion	RegionCache.getRegionByKey(com.google.protobuf.ByteString key, BackOffer backOffer)
Pair<TiRegion,TiStore>	RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key, BackOffer backOffer)
Pair<TiRegion,TiStore>	RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key, TiStoreType storeType, BackOffer backOffer)
TiStore	RegionManager.getStoreById(long id, BackOffer backOffer)
boolean	AbstractRegionStoreClient.onNotLeader(TiRegion newRegion, BackOffer backOffer) onNotLeader deals with NotLeaderError and returns whether re-splitting key range is needed
boolean	RegionErrorReceiver.onNotLeader(TiRegion region, BackOffer backOffer)
boolean	AbstractRegionStoreClient.onStoreUnreachable(BackOffer backOffer)
boolean	RegionErrorReceiver.onStoreUnreachable(BackOffer backOffer)
void	RegionStoreClient.prewrite(BackOffer backOffer, com.google.protobuf.ByteString primary, List<Kvrpcpb.Mutation> mutations, long startTs, long lockTTL) Prewrite batch keys
void	RegionStoreClient.prewrite(BackOffer bo, com.google.protobuf.ByteString primaryLock, List<Kvrpcpb.Mutation> mutations, long startTs, long ttl, boolean skipConstraintCheck) Prewrite batch keys
void	RegionStoreClient.rawBatchDelete(BackOffer backoffer, List<com.google.protobuf.ByteString> keys, boolean atomicForCAS)
List<Kvrpcpb.KvPair>	RegionStoreClient.rawBatchGet(BackOffer backoffer, List<com.google.protobuf.ByteString> keys)
void	RegionStoreClient.rawBatchPut(BackOffer backOffer, Batch batch, long ttl, boolean atomicForCAS)
void	RegionStoreClient.rawBatchPut(BackOffer backOffer, List<Kvrpcpb.KvPair> kvPairs, long ttl, boolean atomicForCAS)
void	RegionStoreClient.rawCompareAndSet(BackOffer backOffer, com.google.protobuf.ByteString key, Optional<com.google.protobuf.ByteString> prevValue, com.google.protobuf.ByteString value, long ttl)
void	RegionStoreClient.rawDelete(BackOffer backOffer, com.google.protobuf.ByteString key, boolean atomicForCAS)
void	RegionStoreClient.rawDeleteRange(BackOffer backOffer, com.google.protobuf.ByteString startKey, com.google.protobuf.ByteString endKey) Delete raw keys in the range of [startKey, endKey)
Optional<com.google.protobuf.ByteString>	RegionStoreClient.rawGet(BackOffer backOffer, com.google.protobuf.ByteString key)
Optional<Long>	RegionStoreClient.rawGetKeyTTL(BackOffer backOffer, com.google.protobuf.ByteString key)
void	RegionStoreClient.rawPut(BackOffer backOffer, com.google.protobuf.ByteString key, com.google.protobuf.ByteString value, long ttl, boolean atomicForCAS)
List<Kvrpcpb.KvPair>	RegionStoreClient.rawScan(BackOffer backOffer, com.google.protobuf.ByteString key, boolean keyOnly)
List<Kvrpcpb.KvPair>	RegionStoreClient.rawScan(BackOffer backOffer, com.google.protobuf.ByteString key, int limit, boolean keyOnly) Return a batch KvPair list containing limited key-value pairs starting from `key`, which are in the same region
List<Kvrpcpb.KvPair>	RegionStoreClient.scan(BackOffer backOffer, com.google.protobuf.ByteString startKey, long version)
List<Kvrpcpb.KvPair>	RegionStoreClient.scan(BackOffer backOffer, com.google.protobuf.ByteString startKey, long version, boolean keyOnly)
List<Pdpb.Region>	RegionManager.scanRegions(BackOffer backOffer, com.google.protobuf.ByteString startKey, com.google.protobuf.ByteString endKey, int limit)
void	RegionStoreClient.txnHeartBeat(BackOffer bo, com.google.protobuf.ByteString primaryLock, long startTs, long ttl) TXN Heart Beat: update primary key ttl

Uses of BackOffer in org.tikv.common.util

Classes in org.tikv.common.util that implement BackOffer

Modifier and Type	Class and Description
class	ConcreteBackOffer

Methods in org.tikv.common.util that return BackOffer

Modifier and Type	Method and Description
BackOffer	DeleteRange.getBackOffer()
BackOffer	Batch.getBackOffer()

Methods in org.tikv.common.util with parameters of type BackOffer

Modifier and Type	Method and Description
static void	ClientUtils.appendBatches(BackOffer backOffer, List<Batch> batches, TiRegion region, List<com.google.protobuf.ByteString> keys, int batchMaxSizeInBytes, int batchLimit) Append batch to list and split them according to batch limit
static void	ClientUtils.appendBatches(BackOffer backOffer, List<Batch> batches, TiRegion region, List<com.google.protobuf.ByteString> keys, List<com.google.protobuf.ByteString> values, int batchMaxSizeInBytes, int batchLimit) Append batch to list and split them according to batch limit
static ConcreteBackOffer	ConcreteBackOffer.create(BackOffer source)
static List<Batch>	ClientUtils.getBatches(BackOffer backOffer, List<com.google.protobuf.ByteString> keys, int batchSize, int batchLimit, RegionStoreClient.RegionStoreClientBuilder clientBuilder)
static Map<TiRegion,List<com.google.protobuf.ByteString>>	ClientUtils.groupKeysByRegion(RegionManager regionManager, List<com.google.protobuf.ByteString> keys, BackOffer backoffer)
static Map<TiRegion,List<com.google.protobuf.ByteString>>	ClientUtils.groupKeysByRegion(RegionManager regionManager, List<com.google.protobuf.ByteString> keys, BackOffer backoffer, boolean sorted) Group by list of keys according to its region
static Map<TiRegion,List<com.google.protobuf.ByteString>>	ClientUtils.groupKeysByRegion(RegionManager regionManager, Set<com.google.protobuf.ByteString> keys, BackOffer backoffer)

Constructors in org.tikv.common.util with parameters of type BackOffer

Constructor and Description
Batch(BackOffer backOffer, TiRegion region, List<com.google.protobuf.ByteString> keys)
Batch(BackOffer backOffer, TiRegion region, List<com.google.protobuf.ByteString> keys, List<com.google.protobuf.ByteString> values)
DeleteRange(BackOffer backOffer, TiRegion region, com.google.protobuf.ByteString startKey, com.google.protobuf.ByteString endKey)

Uses of BackOffer in org.tikv.txn

Methods in org.tikv.txn with parameters of type BackOffer

Modifier and Type	Method and Description
List<Kvrpcpb.KvPair>	KVClient.batchGet(BackOffer backOffer, List<com.google.protobuf.ByteString> keys, long version) Get a set of key-value pair by keys from TiKV
ClientRPCResult	TxnKVClient.commit(BackOffer backOffer, com.google.protobuf.ByteString[] keys, long startTs, long commitTs, TiRegion tiRegion, TiStore store) Commit request of 2pc, add backoff logic when encountered region error, ErrBodyMissing, and other errors
void	TwoPhaseCommitter.commitPrimaryKey(BackOffer backOffer, byte[] key, long commitTs) 2pc - commit primary key
ClientRPCResult	TxnKVClient.prewrite(BackOffer backOffer, List<Kvrpcpb.Mutation> mutations, com.google.protobuf.ByteString primary, long lockTTL, long startTs, TiRegion tiRegion, TiStore store) when encountered region error,ErrBodyMissing, and other errors
void	TwoPhaseCommitter.prewritePrimaryKey(BackOffer backOffer, byte[] primaryKey, byte[] value) 2pc - prewrite primary key
ResolveLockResult	LockResolverClientV3.resolveLocks(BackOffer bo, long callerStartTS, List<Lock> locks, boolean forWrite)
ResolveLockResult	LockResolverClientV2.resolveLocks(BackOffer bo, long callerStartTS, List<Lock> locks, boolean forWrite)
ResolveLockResult	LockResolverClientV4.resolveLocks(BackOffer bo, long callerStartTS, List<Lock> locks, boolean forWrite)
ResolveLockResult	AbstractLockResolverClient.resolveLocks(BackOffer bo, long callerStartTS, List<Lock> locks, boolean forWrite) ResolveLocks tries to resolve Locks.
ClientRPCResult	TxnKVClient.txnHeartBeat(BackOffer backOffer, com.google.protobuf.ByteString primaryLock, long startTs, long ttl, TiRegion tiRegion, TiStore store) TXN Heart Beat: update primary key ttl