Versions in this module Expand all Collapse all v0 v0.0.8 Feb 17, 2022 Changes in this version + const WarnLevelError + const WarnLevelNote + const WarnLevelWarning + func AllocateTaskID() uint64 + type CopTasksDetails struct + AvgBackoffTime map[string]time.Duration + AvgProcessTime time.Duration + AvgWaitTime time.Duration + MaxBackoffAddress map[string]string + MaxBackoffTime map[string]time.Duration + MaxProcessAddress string + MaxProcessTime time.Duration + MaxWaitAddress string + MaxWaitTime time.Duration + NumCopTasks int + P90BackoffTime map[string]time.Duration + P90ProcessTime time.Duration + P90WaitTime time.Duration + TotBackoffTime map[string]time.Duration + TotBackoffTimes map[string]int + func (d *CopTasksDetails) ToZapFields() (fields []zap.Field) + type SQLWarn struct + Err error + Level string + type StatementContext struct + AllowInvalidDate bool + BadNullAsWarning bool + BaseRowID int64 + BatchCheck bool + DividedByZeroAsWarning bool + DupKeyAsWarning bool + IgnoreTruncate bool + IgnoreZeroInDate bool + InDeleteStmt bool + InExplainStmt bool + InInsertStmt bool + InLoadDataStmt bool + InNullRejectCheck bool + InSelectStmt bool + InShowWarning bool + InUpdateStmt bool + IndexNames []string + InsertID uint64 + IsDDLJobInQueue bool + LastInsertID uint64 + LockKeysCount int32 + LockKeysDuration time.Duration + MaxRowID int64 + NotFillCache bool + OriginalSQL string + OverflowAsWarning bool + PessimisticLockWaited int32 + PointExec bool + PrevAffectedRows int64 + PrevLastInsertID uint64 + Priority mysql.PriorityEnum + StmtType string + TableIDs []int64 + Tables []TableEntry + TaskID uint64 + TblInfo2UnionScan map[*model.TableInfo]bool + TimeZone *time.Location + TruncateAsWarning bool + UseCache bool + func (sc *StatementContext) AddAffectedRows(rows uint64) + func (sc *StatementContext) AddCopiedRows(rows uint64) + func (sc *StatementContext) AddFoundRows(rows uint64) + func (sc *StatementContext) AddRecordRows(rows uint64) + func (sc *StatementContext) AddTouchedRows(rows uint64) + func (sc *StatementContext) AddUpdatedRows(rows uint64) + func (sc *StatementContext) AffectedRows() uint64 + func (sc *StatementContext) AppendError(warn error) + func (sc *StatementContext) AppendNote(warn error) + func (sc *StatementContext) AppendWarning(warn error) + func (sc *StatementContext) AppendWarnings(warns []SQLWarn) + func (sc *StatementContext) CopiedRows() uint64 + func (sc *StatementContext) FoundRows() uint64 + func (sc *StatementContext) GetLockWaitStartTime() time.Time + func (sc *StatementContext) GetMessage() string + func (sc *StatementContext) GetNowTsCached() time.Time + func (sc *StatementContext) GetPlanDigest() (normalized, planDigest string) + func (sc *StatementContext) GetWarnings() []SQLWarn + func (sc *StatementContext) HandleOverflow(err error, warnErr error) error + func (sc *StatementContext) HandleTruncate(err error) error + func (sc *StatementContext) InitSQLDigest(normalized, digest string) + func (sc *StatementContext) NumErrorWarnings() (ec uint16, wc int) + func (sc *StatementContext) PushDownFlags() uint64 + func (sc *StatementContext) RecordRows() uint64 + func (sc *StatementContext) ResetForRetry() + func (sc *StatementContext) ResetNowTs() + func (sc *StatementContext) SQLDigest() (normalized, sqlDigest string) + func (sc *StatementContext) SetFlagsFromPBFlag(flags uint64) + func (sc *StatementContext) SetHistogramsNotLoad() + func (sc *StatementContext) SetMessage(msg string) + func (sc *StatementContext) SetPlanDigest(normalized, planDigest string) + func (sc *StatementContext) SetWarnings(warns []SQLWarn) + func (sc *StatementContext) ShouldClipToZero() bool + func (sc *StatementContext) ShouldIgnoreOverflowError() bool + func (sc *StatementContext) TouchedRows() uint64 + func (sc *StatementContext) UpdatedRows() uint64 + func (sc *StatementContext) WarningCount() uint16 + type StmtHints struct + AllowInSubqToJoinAndAgg bool + EnableCascadesPlanner bool + HasAllowInSubqToJoinAndAggHint bool + HasEnableCascadesPlannerHint bool + HasMaxExecutionTime bool + HasMemQuotaHint bool + HasReplicaReadHint bool + MaxExecutionTime uint64 + MemQuotaQuery int64 + NoIndexMergeHint bool + ReplicaRead byte + type TableEntry struct + DB string + Table string