Package | Description |
---|---|
org.tikv.common.importer | |
org.tikv.common.region | |
org.tikv.common.replica | |
org.tikv.common.util | |
org.tikv.txn | |
org.tikv.txn.type |
Modifier and Type | Method and Description |
---|---|
ImporterStoreClient |
ImporterStoreClient.ImporterStoreClientBuilder.build(TiStore store) |
Modifier and Type | Field and Description |
---|---|
protected TiStore |
AbstractRegionStoreClient.store |
Modifier and Type | Method and Description |
---|---|
TiStore |
RegionManager.getStoreById(long id) |
TiStore |
RegionCache.getStoreById(long id) |
TiStore |
RegionManager.getStoreById(long id,
BackOffer backOffer) |
TiStore |
TiStore.withProxy(Metapb.Store proxyStore) |
Modifier and Type | Method and Description |
---|---|
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key) |
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key,
BackOffer backOffer) |
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key,
TiStoreType storeType) |
Pair<TiRegion,TiStore> |
RegionManager.getRegionStorePairByKey(com.google.protobuf.ByteString key,
TiStoreType storeType,
BackOffer backOffer) |
Modifier and Type | Method and Description |
---|---|
RegionStoreClient |
RegionStoreClient.RegionStoreClientBuilder.build(TiRegion region,
TiStore store) |
RegionStoreClient |
RegionStoreClient.RegionStoreClientBuilder.build(TiRegion region,
TiStore store,
TiStoreType storeType) |
void |
RegionCache.invalidateAllRegionForStore(TiStore store) |
boolean |
RegionCache.putStore(long id,
TiStore store) |
boolean |
StoreHealthyChecker.scheduleStoreHealthCheck(TiStore store) |
void |
RegionManager.updateStore(TiStore oldStore,
TiStore newStore) |
boolean |
RegionCache.updateStore(TiStore oldStore,
TiStore newStore) |
Constructor and Description |
---|
AbstractRegionStoreClient(TiConfiguration conf,
TiRegion region,
TiStore store,
ChannelFactory channelFactory,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
RegionManager regionManager) |
Constructor and Description |
---|
TiRegion(TiConfiguration conf,
Metapb.Region meta,
Metapb.Peer leader,
List<Metapb.Peer> peers,
List<TiStore> stores) |
Constructor and Description |
---|
Region(Metapb.Region region,
Metapb.Peer leader,
List<Metapb.Peer> peers,
List<TiStore> stores) |
Modifier and Type | Method and Description |
---|---|
TiStore |
RangeSplitter.RegionTask.getStore() |
Modifier and Type | Method and Description |
---|---|
Map<Pair<TiRegion,TiStore>,gnu.trove.list.array.TLongArrayList> |
RangeSplitter.groupByAndSortHandlesByRegionId(long tableId,
gnu.trove.list.array.TLongArrayList handles)
Group by a list of handles by the handles' region, handles will be sorted.
|
Modifier and Type | Method and Description |
---|---|
static RangeSplitter.RegionTask |
RangeSplitter.RegionTask.newInstance(TiRegion region,
TiStore store,
List<Coprocessor.KeyRange> ranges) |
Modifier and Type | Method and Description |
---|---|
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
|
static AbstractLockResolverClient |
AbstractLockResolverClient.getInstance(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient,
RegionStoreClient.RegionStoreClientBuilder clientBuilder) |
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
|
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
|
Constructor and Description |
---|
LockResolverClientV2(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager) |
LockResolverClientV3(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient,
RegionStoreClient.RegionStoreClientBuilder clientBuilder) |
LockResolverClientV4(TiConfiguration conf,
TiRegion region,
TiStore store,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient,
RegionStoreClient.RegionStoreClientBuilder clientBuilder) |
Modifier and Type | Method and Description |
---|---|
TiStore |
BatchKeys.getStore() |
Modifier and Type | Method and Description |
---|---|
Map<Pair<TiRegion,TiStore>,List<com.google.protobuf.ByteString>> |
GroupKeyResult.getGroupsResult() |
Modifier and Type | Method and Description |
---|---|
void |
GroupKeyResult.setGroupsResult(Map<Pair<TiRegion,TiStore>,List<com.google.protobuf.ByteString>> groupsResult) |
Constructor and Description |
---|
BatchKeys(TiRegion region,
TiStore store,
List<com.google.protobuf.ByteString> keysInput,
int sizeInBytes) |
Copyright © 2024 PingCAP. All rights reserved.