util

package

Go to main page

Versions in this module

v2

v2.0.7

Apr 14, 2023

Changes in this version

+ type RURuntimeStats struct

+ func NewRURuntimeStats() *RURuntimeStats

+ func (rs *RURuntimeStats) Clone() *RURuntimeStats

+ func (rs *RURuntimeStats) Merge(other *RURuntimeStats)

+ func (rs *RURuntimeStats) String() string

+ func (rs *RURuntimeStats) Update(consumption *rmpb.Consumption)

type TimeDetail

+ KvReadWallTime time.Duration

+ SuspendTime time.Duration

v2.0.6

Mar 2, 2023

Changes in this version

+ func IsInternalRequest(source string) bool

+ func IsRequestSourceInternal(reqSrc *RequestSource) bool

type LockKeysDetails

+ AggressiveLockDerivedCount int

+ AggressiveLockNewCount int

+ LockedWithConflictCount int

v2.0.5

Feb 2, 2023

Changes in this version

+ func ResourceGroupNameFromCtx(ctx context.Context) string

+ func WithResouceGroupName(ctx context.Context, groupName string) context.Context

v2.0.4

Jan 6, 2023

v2.0.3

Dec 8, 2022

v2.0.2

Nov 2, 2022

Changes in this version

+ const ExternalRequest

+ const InternalRequest

+ const InternalTxnGC

+ const InternalTxnMeta

+ const InternalTxnOthers

+ const SourceUnknown

+ var RequestSourceKey = RequestSourceKeyType

+ var RequestSourceTypeKey = RequestSourceTypeKeyType

+ func ContextWithTraceExecDetails(ctx context.Context) context.Context

+ func RequestSourceFromCtx(ctx context.Context) string

+ func TraceExecDetailsEnabled(ctx context.Context) bool

+ func WithInternalSourceType(ctx context.Context, source string) context.Context

type CommitDetails

+ GetLatestTsTime time.Duration

+ PrewriteReqNum int

+ ResolveLock ResolveLockDetail

+ func (cd *CommitDetails) MergeCommitReqDetails(reqDuration time.Duration, regionID uint64, addr string, ...)

+ func (cd *CommitDetails) MergePrewriteReqDetails(reqDuration time.Duration, regionID uint64, addr string, ...)

type LockKeysDetails

+ ResolveLock ResolveLockDetail

+ func (ld *LockKeysDetails) MergeReqDetails(reqDuration time.Duration, regionID uint64, addr string, ...)

+ type ReqDetailInfo struct

+ ExecDetails TiKVExecDetails

+ Region uint64

+ ReqTotalTime time.Duration

+ StoreAddr string

+ type RequestSource struct

+ RequestSourceInternal bool

+ RequestSourceType string

+ func (r *RequestSource) GetRequestSource() string

+ func (r *RequestSource) SetRequestSourceInternal(internal bool)

+ func (r *RequestSource) SetRequestSourceType(tp string)

+ type RequestSourceKeyType struct

+ type RequestSourceTypeKeyType struct

+ type ResolveLockDetail struct

+ ResolveLockTime int64

+ func (rd *ResolveLockDetail) Merge(resolveLock *ResolveLockDetail)

type ScanDetail

+ GetSnapshotDuration time.Duration

+ ResolveLock *ResolveLockDetail

+ RocksdbBlockReadDuration time.Duration

+ type TiKVExecDetails struct

+ ScanDetail *ScanDetail

+ TimeDetail *TimeDetail

+ WriteDetail *WriteDetail

+ func NewTiKVExecDetails(pb *kvrpcpb.ExecDetailsV2) TiKVExecDetails

+ func (ed *TiKVExecDetails) String() string

type TimeDetail

+ TotalRPCWallTime time.Duration

+ type WriteDetail struct

+ ApplyBatchWaitDuration time.Duration

+ ApplyLogDuration time.Duration

+ ApplyMutexLockDuration time.Duration

+ ApplyWriteLeaderWaitDuration time.Duration

+ ApplyWriteMemtableDuration time.Duration

+ ApplyWriteWalDuration time.Duration

+ CommitLogDuration time.Duration

+ PersistLogDuration time.Duration

+ ProposeSendWaitDuration time.Duration

+ RaftDbSyncLogDuration time.Duration

+ RaftDbWriteLeaderWaitDuration time.Duration

+ RaftDbWriteMemtableDuration time.Duration

+ StoreBatchWaitDuration time.Duration

+ func (wd *WriteDetail) Merge(writeDetail *WriteDetail)

+ func (wd *WriteDetail) MergeFromWriteDetailPb(pb *kvrpcpb.WriteDetail)

+ func (wd *WriteDetail) String() string

v2.0.1

Apr 7, 2022

v2.0.0

Feb 24, 2022

Changes in this version

+ const GCTimeFormat

+ var CommitDetailCtxKey = commitDetailCtxKeyType

+ var ExecDetailsKey = execDetailsCtxKeyType

+ var LockKeysDetailCtxKey = lockKeysDetailCtxKeyType

+ var SessionID = sessionIDCtxKey

+ func BytesToString(numBytes int64) string

+ func CompatibleParseGCTime(value string) (time.Time, error)

+ func EnableFailpoints()

+ func EncodeToString(src []byte) []byte

+ func EvalFailpoint(name string) (interface{}, error)

+ func FormatBytes(numBytes int64) string

+ func FormatDuration(d time.Duration) string

+ func HexRegionKey(key []byte) []byte

+ func HexRegionKeyStr(key []byte) string

+ func SetSessionID(ctx context.Context, sessionID uint64) context.Context

+ func String(b []byte) (s string)

+ func ToUpperASCIIInplace(s []byte) []byte

+ func WithRecovery(exec func(), recoverFn func(r interface{}))

+ type CommitDetails struct

+ CommitTime time.Duration

+ GetCommitTsTime time.Duration

+ LocalLatchTime time.Duration

+ Mu struct{ ... }

+ PrewriteRegionNum int32

+ PrewriteTime time.Duration

+ ResolveLockTime int64

+ TxnRetry int

+ WaitPrewriteBinlogTime time.Duration

+ WriteKeys int

+ WriteSize int

+ func (cd *CommitDetails) Clone() *CommitDetails

+ func (cd *CommitDetails) Merge(other *CommitDetails)

+ type ExecDetails struct

+ BackoffCount int64

+ BackoffDuration int64

+ WaitKVRespDuration int64

+ WaitPDRespDuration int64

+ type InterceptedPDClient struct

+ func (m InterceptedPDClient) GetPrevRegion(ctx context.Context, key []byte) (*pd.Region, error)

+ func (m InterceptedPDClient) GetRegion(ctx context.Context, key []byte) (*pd.Region, error)

+ func (m InterceptedPDClient) GetRegionByID(ctx context.Context, regionID uint64) (*pd.Region, error)

+ func (m InterceptedPDClient) GetStore(ctx context.Context, storeID uint64) (*metapb.Store, error)

+ func (m InterceptedPDClient) GetTS(ctx context.Context) (int64, int64, error)

+ func (m InterceptedPDClient) GetTSAsync(ctx context.Context) pd.TSFuture

+ func (m InterceptedPDClient) ScanRegions(ctx context.Context, key, endKey []byte, limit int) ([]*pd.Region, error)

+ type LockKeysDetails struct

+ BackoffTime int64

+ LockKeys int32

+ LockRPCCount int64

+ LockRPCTime int64

+ Mu struct{ ... }

+ RegionNum int32

+ ResolveLockTime int64

+ RetryCount int

+ TotalTime time.Duration

+ func (ld *LockKeysDetails) Clone() *LockKeysDetails

+ func (ld *LockKeysDetails) Merge(lockKey *LockKeysDetails)

+ type RateLimit struct

+ func NewRateLimit(n int) *RateLimit

+ func (r *RateLimit) GetCapacity() int

+ func (r *RateLimit) GetToken(done <-chan struct{}) (exit bool)

+ func (r *RateLimit) PutToken()

+ type ScanDetail struct

+ ProcessedKeys int64

+ ProcessedKeysSize int64

+ RocksdbBlockCacheHitCount uint64

+ RocksdbBlockReadByte uint64

+ RocksdbBlockReadCount uint64

+ RocksdbDeleteSkippedCount uint64

+ RocksdbKeySkippedCount uint64

+ TotalKeys int64

+ func (sd *ScanDetail) Merge(scanDetail *ScanDetail)

+ func (sd *ScanDetail) MergeFromScanDetailV2(scanDetail *kvrpcpb.ScanDetailV2)

+ func (sd *ScanDetail) String() string

+ type TSSet struct

+ func (s *TSSet) GetAll() []uint64

+ func (s *TSSet) Put(tss ...uint64)

+ type TimeDetail struct

+ KvReadWallTimeMs time.Duration

+ ProcessTime time.Duration

+ WaitTime time.Duration

+ func (td *TimeDetail) MergeFromTimeDetail(timeDetail *kvrpcpb.TimeDetail)

+ func (td *TimeDetail) String() string

v2.0.0-rc

Dec 6, 2021

v2.0.0-alpha

Jun 23, 2021

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL