Versions in this module Expand all Collapse all v2 v2.5.4 Dec 8, 2022 v2.5.3 Dec 7, 2022 v2.5.2 Dec 7, 2022 v2.5.1 Dec 1, 2022 v2.5.0 Dec 1, 2022 v2.1.0 Dec 1, 2022 Changes in this version + type ClientHelper struct + func NewClientHelper(store kvstore, resolvedLocks *util.TSSet, resolveLite bool) *ClientHelper + func (ch *ClientHelper) ResolveLocks(bo *retry.Backoffer, callerStartTS uint64, locks []*txnlock.Lock) (int64, error) + func (ch *ClientHelper) SendReqCtx(bo *retry.Backoffer, req *tikvrpc.Request, regionID locate.RegionVerID, ...) (*tikvrpc.Response, *locate.RPCContext, string, error) + type ConfigProbe struct + func (c ConfigProbe) GetGetMaxBackoff() int + func (c ConfigProbe) GetScanBatchSize() int + type IsoLevel kvrpcpb.IsolationLevel + const RC + const SI + func (l IsoLevel) ToPB() kvrpcpb.IsolationLevel + type KVSnapshot struct + func NewTiKVSnapshot(store kvstore, ts uint64, replicaReadSeed uint32) *KVSnapshot + func (s *KVSnapshot) BatchGet(ctx context.Context, keys [][]byte) (map[string][]byte, error) + func (s *KVSnapshot) Get(ctx context.Context, k []byte) ([]byte, error) + func (s *KVSnapshot) Iter(k []byte, upperBound []byte) (unionstore.Iterator, error) + func (s *KVSnapshot) IterReverse(k []byte) (unionstore.Iterator, error) + func (s *KVSnapshot) SetIsStatenessReadOnly(b bool) + func (s *KVSnapshot) SetIsolationLevel(level IsoLevel) + func (s *KVSnapshot) SetKeyOnly(b bool) + func (s *KVSnapshot) SetMatchStoreLabels(labels []*metapb.StoreLabel) + func (s *KVSnapshot) SetNotFillCache(b bool) + func (s *KVSnapshot) SetPriority(pri txnutil.Priority) + func (s *KVSnapshot) SetReadReplicaScope(scope string) + func (s *KVSnapshot) SetReplicaRead(readType kv.ReplicaReadType) + func (s *KVSnapshot) SetResourceGroupTag(tag []byte) + func (s *KVSnapshot) SetRuntimeStats(stats *SnapshotRuntimeStats) + func (s *KVSnapshot) SetSampleStep(step uint32) + func (s *KVSnapshot) SetScanBatchSize(batchSize int) + func (s *KVSnapshot) SetSnapshotTS(ts uint64) + func (s *KVSnapshot) SetTaskID(id uint64) + func (s *KVSnapshot) SetTxnScope(scope string) + func (s *KVSnapshot) SetVars(vars *kv.Variables) + func (s *KVSnapshot) SnapCacheHitCount() int + func (s *KVSnapshot) SnapCacheSize() int + type Scanner struct + func (s *Scanner) Close() + func (s *Scanner) Key() []byte + func (s *Scanner) Next() error + func (s *Scanner) Valid() bool + func (s *Scanner) Value() []byte + type SnapshotProbe struct + func (s SnapshotProbe) BatchGetSingleRegion(bo *retry.Backoffer, region locate.RegionVerID, keys [][]byte, ...) error + func (s SnapshotProbe) FormatStats() string + func (s SnapshotProbe) MergeExecDetail(detail *kvrpcpb.ExecDetailsV2) + func (s SnapshotProbe) MergeRegionRequestStats(stats map[tikvrpc.CmdType]*locate.RPCRuntimeStats) + func (s SnapshotProbe) NewScanner(start, end []byte, batchSize int, reverse bool) (*Scanner, error) + func (s SnapshotProbe) RecordBackoffInfo(bo *retry.Backoffer) + type SnapshotRuntimeStats struct + func (rs *SnapshotRuntimeStats) Clone() *SnapshotRuntimeStats + func (rs *SnapshotRuntimeStats) Merge(other *SnapshotRuntimeStats) + func (rs *SnapshotRuntimeStats) String() string
Go to main page