Versions in this module Expand all Collapse all v2 v2.0.7 Apr 14, 2023 v2.0.6 Mar 2, 2023 Changes in this version type KVSnapshot + func (s *KVSnapshot) IsInternal() bool + func (s *KVSnapshot) SetLoadBasedReplicaReadThreshold(busyThreshold time.Duration) v2.0.5 Feb 2, 2023 Changes in this version type KVSnapshot + func (s *KVSnapshot) SetResourceGroupName(name string) v2.0.4 Jan 6, 2023 v2.0.3 Dec 8, 2022 v2.0.2 Nov 2, 2022 Changes in this version + const DefaultScanBatchSize type ClientHelper + func (ch *ClientHelper) RecordResolvingLocks(locks []*txnlock.Lock, callerStartTS uint64) int + func (ch *ClientHelper) ResolveLocksDone(callerStartTS uint64, token int) + func (ch *ClientHelper) ResolveLocksWithOpts(bo *retry.Backoffer, opts txnlock.ResolveLocksOptions) (txnlock.ResolveLockResult, error) + func (ch *ClientHelper) UpdateResolvingLocks(locks []*txnlock.Lock, callerStartTS uint64, token int) type IsoLevel + const RCCheckTS type KVSnapshot + func (s *KVSnapshot) SetIsStalenessReadOnly(b bool) + func (s *KVSnapshot) SetReplicaReadAdjuster(f ReplicaReadAdjuster) + type ReplicaReadAdjuster func(int) (locate.StoreSelectorOption, kv.ReplicaReadType) v2.0.1 Apr 7, 2022 v2.0.0 Feb 24, 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 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 v2.0.0-rc Dec 6, 2021
Go to main page