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 |
Snapshot.getConf() |
TiConfiguration |
AbstractGRPCClient.getConf() |
TiConfiguration |
TiSession.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 © 2024 PingCAP. All rights reserved.