Versions in this module Expand all Collapse all v3 v3.1.3 Jul 5, 2022 v3.1.2 Jun 6, 2022 v3.1.1 Jun 6, 2022 v3.1.0 May 17, 2022 v3.0.9 May 17, 2022 v3.0.8 May 3, 2022 v3.0.7 May 3, 2022 v3.0.6 May 3, 2022 v3.0.5 May 2, 2022 v3.0.4 May 1, 2022 v3.0.3 May 1, 2022 v3.0.0 May 1, 2022 Changes in this version + type ClientHelper struct + func NewClientHelper(store kvstore, resolvedLocks *util.TSSet, committedLocks *util.TSSet, ...) *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 RCCheckTS + const SI + func (l IsoLevel) ToPB() kvrpcpb.IsolationLevel + type KVSnapshot struct + func NewTiKVSnapshot(store kvstore, ts uint64, replicaReadSeed uint32) *KVSnapshot + func (s *KVSnapshot) AddRPCInterceptor(it interceptor.RPCInterceptor) + 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) SetRPCInterceptor(it interceptor.RPCInterceptor) + func (s *KVSnapshot) SetReadReplicaScope(scope string) + func (s *KVSnapshot) SetReplicaRead(readType kv.ReplicaReadType) + func (s *KVSnapshot) SetResourceGroupTag(tag []byte) + func (s *KVSnapshot) SetResourceGroupTagger(tagger tikvrpc.ResourceGroupTagger) + 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