public class TiConfiguration extends Object implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
TiConfiguration.ApiVersion |
static class |
TiConfiguration.KVMode |
static class |
TiConfiguration.ReplicaRead |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.ByteString |
API_V2_RAW_PREFIX |
static com.google.protobuf.ByteString |
API_V2_TXN_PREFIX |
static io.grpc.Metadata.Key<String> |
FORWARD_META_DATA_KEY |
static io.grpc.Metadata.Key<String> |
PD_FORWARD_META_DATA_KEY |
Constructor and Description |
---|
TiConfiguration() |
public static final io.grpc.Metadata.Key<String> FORWARD_META_DATA_KEY
public static final io.grpc.Metadata.Key<String> PD_FORWARD_META_DATA_KEY
public static final com.google.protobuf.ByteString API_V2_RAW_PREFIX
public static final com.google.protobuf.ByteString API_V2_TXN_PREFIX
public static void listAll()
public static int getInt(String key)
public static TiConfiguration createDefault()
public static TiConfiguration createDefault(String pdAddrsStr)
public static TiConfiguration createRawDefault()
public static TiConfiguration createRawDefault(String pdAddrsStr)
public long getTimeout()
public TiConfiguration setTimeout(long timeout)
public long getIngestTimeout()
public void setIngestTimeout(long ingestTimeout)
public long getForwardTimeout()
public TiConfiguration setForwardTimeout(long timeout)
public long getWarmUpTimeout()
public TiConfiguration setWarmUpTimeout(long timeout)
public long getPdFirstGetMemberTimeout()
public void setPdFirstGetMemberTimeout(long pdFirstGetMemberTimeout)
public long getScanTimeout()
public TiConfiguration setScanTimeout(long scanTimeout)
public String getPdAddrsString()
public int getScanBatchSize()
public int getMaxFrameSize()
public TiConfiguration setMaxFrameSize(int maxFrameSize)
public long getConnRecycleTimeInSeconds()
public TiConfiguration setConnRecycleTimeInSeconds(int connRecycleTime)
public int getIndexScanBatchSize()
public TiConfiguration setIndexScanBatchSize(int indexScanBatchSize)
public int getIndexScanConcurrency()
public TiConfiguration setIndexScanConcurrency(int indexScanConcurrency)
public int getTableScanConcurrency()
public TiConfiguration setTableScanConcurrency(int tableScanConcurrency)
public int getBatchGetConcurrency()
public TiConfiguration setBatchGetConcurrency(int batchGetConcurrency)
public int getBatchPutConcurrency()
public TiConfiguration setBatchPutConcurrency(int batchPutConcurrency)
public int getBatchDeleteConcurrency()
public TiConfiguration setBatchDeleteConcurrency(int batchDeleteConcurrency)
public int getBatchScanConcurrency()
public TiConfiguration setBatchScanConcurrency(int batchScanConcurrency)
public int getDeleteRangeConcurrency()
public TiConfiguration setDeleteRangeConcurrency(int deleteRangeConcurrency)
public Kvrpcpb.CommandPri getCommandPriority()
public TiConfiguration setCommandPriority(Kvrpcpb.CommandPri commandPriority)
public Kvrpcpb.IsolationLevel getIsolationLevel()
public TiConfiguration setIsolationLevel(Kvrpcpb.IsolationLevel isolationLevel)
public boolean ifShowRowId()
public TiConfiguration setShowRowId(boolean flag)
public String getDBPrefix()
public TiConfiguration setDBPrefix(String dbPrefix)
public TiConfiguration.KVMode getKvMode()
public boolean isRawKVMode()
public boolean isTxnKVMode()
public TiConfiguration setKvMode(String kvMode)
public int getKvClientConcurrency()
public TiConfiguration setKvClientConcurrency(int kvClientConcurrency)
public TiConfiguration.ReplicaRead getReplicaRead()
public TiConfiguration setReplicaRead(TiConfiguration.ReplicaRead replicaRead)
public ReplicaSelector getReplicaSelector()
public void setReplicaSelector(ReplicaSelector replicaSelector)
public boolean isMetricsEnable()
public TiConfiguration setMetricsEnable(boolean metricsEnable)
public int getMetricsPort()
public TiConfiguration setMetricsPort(int metricsPort)
public String getNetworkMappingName()
public HostMapping getHostMapping()
public void setHostMapping(HostMapping mapping)
public boolean getEnableGrpcForward()
public void setEnableGrpcForward(boolean enableGrpcForward)
public long getGrpcHealthCheckTimeout()
public void setGrpcHealthCheckTimeout(int grpcHealthCheckTimeout)
public long getHealthCheckPeriodDuration()
public void setHealthCheckPeriodDuration(int healthCheckPeriodDuration)
public boolean isEnableAtomicForCAS()
public void setEnableAtomicForCAS(boolean enableAtomicForCAS)
public int getImporterMaxKVBatchBytes()
public void setImporterMaxKVBatchBytes(int importerMaxKVBatchBytes)
public int getImporterMaxKVBatchSize()
public void setImporterMaxKVBatchSize(int importerMaxKVBatchSize)
public int getScatterWaitSeconds()
public void setScatterWaitSeconds(int scatterWaitSeconds)
public int getRawKVDefaultBackoffInMS()
public void setRawKVDefaultBackoffInMS(int rawKVDefaultBackoffInMS)
public boolean isTest()
public void setTest(boolean test)
public int getKeepaliveTime()
public void setKeepaliveTime(int keepaliveTime)
public int getKeepaliveTimeout()
public void setKeepaliveTimeout(int timeout)
public int getIdleTimeout()
public void setIdleTimeout(int timeout)
public boolean isTiFlashEnabled()
public boolean isWarmUpEnable()
public void setWarmUpEnable(boolean warmUpEnable)
public boolean isTlsEnable()
public long getCertReloadIntervalInSeconds()
public TiConfiguration setCertReloadIntervalInSeconds(long interval)
public void setTlsEnable(boolean tlsEnable)
public String getTrustCertCollectionFile()
public void setTrustCertCollectionFile(String trustCertCollectionFile)
public String getKeyCertChainFile()
public void setKeyCertChainFile(String keyCertChainFile)
public String getKeyFile()
public void setKeyFile(String keyFile)
public boolean isJksEnable()
public void setJksEnable(boolean useJks)
public String getJksKeyPath()
public void setJksKeyPath(String jksKeyPath)
public String getJksKeyPassword()
public void setJksKeyPassword(String jksKeyPassword)
public String getJksTrustPath()
public void setJksTrustPath(String jksTrustPath)
public String getJksTrustPassword()
public void setJksTrustPassword(String jksTrustPassword)
public int getRawKVReadTimeoutInMS()
public void setRawKVReadTimeoutInMS(int rawKVReadTimeoutInMS)
public int getRawKVWriteTimeoutInMS()
public void setRawKVWriteTimeoutInMS(int rawKVWriteTimeoutInMS)
public int getRawKVBatchReadTimeoutInMS()
public void setRawKVBatchReadTimeoutInMS(int rawKVBatchReadTimeoutInMS)
public int getRawKVBatchWriteTimeoutInMS()
public void setRawKVBatchWriteTimeoutInMS(int rawKVBatchWriteTimeoutInMS)
public int getRawKVScanTimeoutInMS()
public void setRawKVScanTimeoutInMS(int rawKVScanTimeoutInMS)
public int getRawKVCleanTimeoutInMS()
public void setRawKVCleanTimeoutInMS(int rawKVCleanTimeoutInMS)
public Integer getRawKVReadSlowLogInMS()
public void setRawKVReadSlowLogInMS(Integer rawKVReadSlowLogInMS)
public Integer getRawKVWriteSlowLogInMS()
public void setRawKVWriteSlowLogInMS(Integer rawKVWriteSlowLogInMS)
public Integer getRawKVBatchReadSlowLogInMS()
public void setRawKVBatchReadSlowLogInMS(Integer rawKVBatchReadSlowLogInMS)
public Integer getRawKVBatchWriteSlowLogInMS()
public void setRawKVBatchWriteSlowLogInMS(Integer rawKVBatchWriteSlowLogInMS)
public int getRawKVScanSlowLogInMS()
public void setRawKVScanSlowLogInMS(int rawKVScanSlowLogInMS)
public double getRawKVServerSlowLogFactor()
public void setRawKVServerSlowLogFactor(double rawKVServerSlowLogFactor)
public boolean isCircuitBreakEnable()
public void setCircuitBreakEnable(boolean circuitBreakEnable)
public int getCircuitBreakAvailabilityWindowInSeconds()
public void setCircuitBreakAvailabilityWindowInSeconds(int circuitBreakAvailabilityWindowInSeconds)
public int getCircuitBreakAvailabilityErrorThresholdPercentage()
public void setCircuitBreakAvailabilityErrorThresholdPercentage(int circuitBreakAvailabilityErrorThresholdPercentage)
public int getCircuitBreakAvailabilityRequestVolumnThreshold()
public void setCircuitBreakAvailabilityRequestVolumnThreshold(int circuitBreakAvailabilityRequestVolumnThreshold)
public int getCircuitBreakSleepWindowInSeconds()
public void setCircuitBreakSleepWindowInSeconds(int circuitBreakSleepWindowInSeconds)
public int getCircuitBreakAttemptRequestCount()
public void setCircuitBreakAttemptRequestCount(int circuitBreakAttemptRequestCount)
public int getScanRegionsLimit()
public void setScanRegionsLimit(int scanRegionsLimit)
public TiConfiguration.ApiVersion getApiVersion()
public TiConfiguration setApiVersion(TiConfiguration.ApiVersion version)
Copyright © 2024 PingCAP. All rights reserved.