| Package | Description |
|---|---|
| org.tikv.common | |
| org.tikv.common.importer | |
| org.tikv.common.operation.iterator | |
| org.tikv.common.region | |
| org.tikv.service.failsafe | |
| org.tikv.txn |
| Modifier and Type | Field and Description |
|---|---|
protected TiConfiguration |
AbstractGRPCClient.conf |
| Modifier and Type | Method and Description |
|---|---|
static TiConfiguration |
TiConfiguration.createDefault() |
static TiConfiguration |
TiConfiguration.createDefault(String pdAddrsStr) |
static TiConfiguration |
TiConfiguration.createRawDefault() |
static TiConfiguration |
TiConfiguration.createRawDefault(String pdAddrsStr) |
TiConfiguration |
TiSession.getConf() |
TiConfiguration |
AbstractGRPCClient.getConf() |
TiConfiguration |
Snapshot.getConf() |
TiConfiguration |
TiConfiguration.setApiVersion(TiConfiguration.ApiVersion version) |
TiConfiguration |
TiConfiguration.setBatchDeleteConcurrency(int batchDeleteConcurrency) |
TiConfiguration |
TiConfiguration.setBatchGetConcurrency(int batchGetConcurrency) |
TiConfiguration |
TiConfiguration.setBatchPutConcurrency(int batchPutConcurrency) |
TiConfiguration |
TiConfiguration.setBatchScanConcurrency(int batchScanConcurrency) |
TiConfiguration |
TiConfiguration.setCertReloadIntervalInSeconds(long interval) |
TiConfiguration |
TiConfiguration.setCommandPriority(Kvrpcpb.CommandPri commandPriority) |
TiConfiguration |
TiConfiguration.setConnRecycleTimeInSeconds(int connRecycleTime) |
TiConfiguration |
TiConfiguration.setDBPrefix(String dbPrefix) |
TiConfiguration |
TiConfiguration.setDeleteRangeConcurrency(int deleteRangeConcurrency) |
TiConfiguration |
TiConfiguration.setForwardTimeout(long timeout) |
TiConfiguration |
TiConfiguration.setIndexScanBatchSize(int indexScanBatchSize) |
TiConfiguration |
TiConfiguration.setIndexScanConcurrency(int indexScanConcurrency) |
TiConfiguration |
TiConfiguration.setIsolationLevel(Kvrpcpb.IsolationLevel isolationLevel) |
TiConfiguration |
TiConfiguration.setKvClientConcurrency(int kvClientConcurrency) |
TiConfiguration |
TiConfiguration.setKvMode(String kvMode) |
TiConfiguration |
TiConfiguration.setMaxFrameSize(int maxFrameSize) |
TiConfiguration |
TiConfiguration.setMetricsEnable(boolean metricsEnable) |
TiConfiguration |
TiConfiguration.setMetricsPort(int metricsPort) |
TiConfiguration |
TiConfiguration.setReplicaRead(TiConfiguration.ReplicaRead replicaRead) |
TiConfiguration |
TiConfiguration.setScanTimeout(long scanTimeout) |
TiConfiguration |
TiConfiguration.setShowRowId(boolean flag) |
TiConfiguration |
TiConfiguration.setTableScanConcurrency(int tableScanConcurrency) |
TiConfiguration |
TiConfiguration.setTimeout(long timeout) |
TiConfiguration |
TiConfiguration.setWarmUpTimeout(long timeout) |
| Modifier and Type | Method and Description |
|---|---|
static TiSession |
TiSession.create(TiConfiguration conf) |
static ReadOnlyPDClient |
PDClient.create(TiConfiguration conf,
RequestKeyCodec codec,
ChannelFactory channelFactory) |
static TiSession |
TiSession.getInstance(TiConfiguration conf)
Deprecated.
|
static MetricsServer |
MetricsServer.getInstance(TiConfiguration conf) |
| Constructor and Description |
|---|
AbstractGRPCClient(TiConfiguration conf,
ChannelFactory channelFactory) |
AbstractGRPCClient(TiConfiguration conf,
ChannelFactory channelFactory,
BlockingStubT blockingStub,
FutureStubT asyncStub) |
TiSession(TiConfiguration conf) |
| Constructor and Description |
|---|
ImporterStoreClient(TiConfiguration conf,
ChannelFactory channelFactory,
ImportSSTGrpc.ImportSSTBlockingStub blockingStub,
ImportSSTGrpc.ImportSSTFutureStub asyncStub,
ImportSSTGrpc.ImportSSTStub stub) |
ImporterStoreClientBuilder(TiConfiguration conf,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient) |
| Modifier and Type | Field and Description |
|---|---|
protected TiConfiguration |
ScanIterator.conf |
| Constructor and Description |
|---|
ConcreteScanIterator(TiConfiguration conf,
RegionStoreClient.RegionStoreClientBuilder builder,
com.google.protobuf.ByteString startKey,
com.google.protobuf.ByteString endKey,
long version) |
ConcreteScanIterator(TiConfiguration conf,
RegionStoreClient.RegionStoreClientBuilder builder,
com.google.protobuf.ByteString startKey,
long version,
int limit) |
RawScanIterator(TiConfiguration conf,
RegionStoreClient.RegionStoreClientBuilder builder,
com.google.protobuf.ByteString startKey,
com.google.protobuf.ByteString endKey,
int limit,
boolean keyOnly,
BackOffer scanBackOffer) |
| Modifier and Type | Method and Description |
|---|---|
TiConfiguration |
TiRegion.getConf() |
| Constructor and Description |
|---|
AbstractRegionStoreClient(TiConfiguration conf,
TiRegion region,
TiStore store,
ChannelFactory channelFactory,
TikvGrpc.TikvBlockingStub blockingStub,
TikvGrpc.TikvFutureStub asyncStub,
RegionManager regionManager) |
RegionManager(TiConfiguration conf,
ReadOnlyPDClient pdClient) |
RegionManager(TiConfiguration conf,
ReadOnlyPDClient pdClient,
ChannelFactory channelFactory) |
RegionManager(TiConfiguration conf,
ReadOnlyPDClient pdClient,
ChannelFactory channelFactory,
int callBackExecutorThreadNum) |
RegionManager(TiConfiguration conf,
ReadOnlyPDClient pdClient,
int callBackExecutorThreadNum) |
RegionStoreClientBuilder(TiConfiguration conf,
ChannelFactory channelFactory,
RegionManager regionManager,
PDClient pdClient) |
TiRegion(TiConfiguration conf,
Metapb.Region meta,
Metapb.Peer leader,
List<Metapb.Peer> peers,
List<TiStore> stores) |
| Constructor and Description |
|---|
CircuitBreakerImpl(TiConfiguration conf,
long clusterId) |
| Modifier and Type | Method and Description |
|---|---|
TiConfiguration |
TxnKVClient.getConf() |
| Modifier and Type | Method and Description |
|---|---|
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) |
Copyright © 2025 PingCAP. All rights reserved.